diff --git a/src/sentry/runner/commands/run.py b/src/sentry/runner/commands/run.py index 22177b9100e014..f7bffa75f3b7ba 100644 --- a/src/sentry/runner/commands/run.py +++ b/src/sentry/runner/commands/run.py @@ -263,6 +263,8 @@ def taskworker_scheduler(redis_cluster: str, **options: Any) -> None: for module in settings.TASKWORKER_IMPORTS: __import__(module) + logger = logging.getLogger("sentry.runner.commands.run") + run_storage = RunStorage(redis_clusters.get(redis_cluster)) with managed_bgtasks(role="taskworker-scheduler"): @@ -272,6 +274,14 @@ def taskworker_scheduler(redis_cluster: str, **options: Any) -> None: if key in enabled_schedules: runner.add(key, schedule_data) + logger.info( + "taskworker.scheduler.schedule_data", + extra={ + "enabled": enabled_schedules, + "available": list(settings.TASKWORKER_SCHEDULES.keys()), + }, + ) + runner.log_startup() while True: sleep_time = runner.tick()