diff --git a/sentry_sdk/integrations/arq.py b/sentry_sdk/integrations/arq.py index c356347dad..1ea8e32fb3 100644 --- a/sentry_sdk/integrations/arq.py +++ b/sentry_sdk/integrations/arq.py @@ -199,12 +199,13 @@ def _sentry_create_worker(*args, **kwargs): if isinstance(settings_cls, dict): if "functions" in settings_cls: settings_cls["functions"] = [ - _get_arq_function(func) for func in settings_cls["functions"] + _get_arq_function(func) + for func in settings_cls.get("functions", []) ] if "cron_jobs" in settings_cls: settings_cls["cron_jobs"] = [ _get_arq_cron_job(cron_job) - for cron_job in settings_cls["cron_jobs"] + for cron_job in settings_cls.get("cron_jobs", []) ] if hasattr(settings_cls, "functions"): @@ -218,11 +219,11 @@ def _sentry_create_worker(*args, **kwargs): if "functions" in kwargs: kwargs["functions"] = [ - _get_arq_function(func) for func in kwargs["functions"] + _get_arq_function(func) for func in kwargs.get("functions", []) ] if "cron_jobs" in kwargs: kwargs["cron_jobs"] = [ - _get_arq_cron_job(cron_job) for cron_job in kwargs["cron_jobs"] + _get_arq_cron_job(cron_job) for cron_job in kwargs.get("cron_jobs", []) ] return old_create_worker(*args, **kwargs)