feat(apscheduler): Add cron monitoring for scheduled jobs

.github/workflows/test-integrations-tasks.yml

@@ -53,6 +53,10 @@ jobs:
       - name: Setup Test Env
         run: |
           uv sync
+      - name: Test apscheduler
+        run: |
+          set -x # print commands that are executed
+          ./scripts/runtox.sh "py${{ matrix.python-version }}-apscheduler"
       - name: Test arq
         run: |
           set -x # print commands that are executed

pyproject.toml

@@ -245,6 +245,10 @@ ignore_missing_imports = true
 module = "huey.*"
 ignore_missing_imports = true
 
+[[tool.mypy.overrides]]
+module = "apscheduler.*"
+ignore_missing_imports = true
+
 [[tool.mypy.overrides]]
 module = "openai.*"
 ignore_missing_imports = true

scripts/populate_tox/config.py

@@ -39,6 +39,11 @@
         "python": ">=3.8",
         "num_versions": 2,
     },
+    "apscheduler": {
+        "package": "apscheduler",
+        # 4.x is a rewrite with a different API and isn't supported.
+        "include": "<4",
+    },
     "arq": {
         "package": "arq",
         "deps": {

scripts/split_tox_gh_actions/split_tox_gh_actions.py

@@ -136,6 +136,7 @@
         "requests",
     ],
     "Tasks": [
+        "apscheduler",
         "arq",
         "beam",
         "celery",

sentry_sdk/crons/decorator.py

@@ -126,12 +126,14 @@
             with self:
                 return await fn(*args, **kwargs)
 
+        inner._sentry_monitored = True  # type: ignore[attr-defined]
         return inner
 
     def _sync_wrapper(self, fn: "Callable[P, R]") -> "Callable[P, R]":
         @wraps(fn)
         def inner(*args: "P.args", **kwargs: "P.kwargs") -> "R":
             with self:
                 return fn(*args, **kwargs)
 
+        inner._sentry_monitored = True  # type: ignore[attr-defined]
         return inner

sentry_sdk/crons/utils.py

@@ -1,7 +1,10 @@
+from datetime import timedelta, timezone
+from functools import lru_cache
 from typing import TYPE_CHECKING
 
 if TYPE_CHECKING:
-    from typing import Optional, Tuple
+    from datetime import tzinfo
+    from typing import FrozenSet, Optional, Set, Tuple
 
     from sentry_sdk._types import MonitorConfigSchedule, MonitorConfigScheduleUnit
 
@@ -27,3 +30,53 @@ def _get_interval_schedule(seconds: float) -> "Optional[MonitorConfigSchedule]":
                 "unit": unit,
             }
     return None
+
+
+@lru_cache(maxsize=None)
+def _get_iana_timezone_names() -> "FrozenSet[str]":
+    names: "Set[str]" = set()
+    try:
+        from zoneinfo import available_timezones
+
+        names.update(available_timezones())
+    except ImportError:
+        try:
+            from backports.zoneinfo import (  # type: ignore[import-not-found, no-redef]
+                available_timezones,
+            )
+
+            names.update(available_timezones())
+        except ImportError:
+            pass
+
+    try:
+        import pytz  # type: ignore[import-untyped]
+
+        # pytz's lazy set looks empty to set.update until it's iterated.
+        names.update(iter(pytz.all_timezones_set))
+    except ImportError:
+        pass
+
+    # Some systems keep these files in the zoneinfo directory, but they aren't zones.
+    names.difference_update(("localtime", "posixrules"))
+    return frozenset(names)
+
+
+def _get_timezone_name(tz: "tzinfo") -> "Optional[str]":
+    """
+    Return the IANA name of the timezone, or None if it has none.
+    """
+    # zoneinfo and pytz. tzlocal can give a zone a non-IANA key, like "local"
+    # or the basename of a TZ file path.
+    name = getattr(tz, "key", None) or getattr(tz, "zone", None)
+    if isinstance(name, str):
+        return name if name in _get_iana_timezone_names() else None
+
+    if isinstance(tz, timezone):
+        offset = tz.utcoffset(None)
+        if offset % timedelta(hours=1):
+            return None
+        hours = offset // timedelta(hours=1)
+        return "Etc/GMT%+d" % -hours if hours else "UTC"
+
+    return None

sentry_sdk/integrations/__init__.py

@@ -121,6 +121,7 @@ def iter_default_integrations(
     "aiohttp": (3, 4),
     "aiomysql": (0, 3, 0),
     "anthropic": (0, 16),
+    "apscheduler": (3, 3),
     "ariadne": (0, 20),
     "arq": (0, 23),
     "asyncpg": (0, 23),