diff --git a/bolt-code/bolt/code/ruff_defaults.toml b/bolt-code/bolt/code/ruff_defaults.toml index 3d2de70d37..c2f521b175 100644 --- a/bolt-code/bolt/code/ruff_defaults.toml +++ b/bolt-code/bolt/code/ruff_defaults.toml @@ -17,4 +17,5 @@ extend-select = [ # # "G", # flake8-logging-format # # "T20", # print "PT", # pytest + "B006", # mutable-argument-default ] diff --git a/bolt-worker/bolt/worker/scheduling.py b/bolt-worker/bolt/worker/scheduling.py index 7064f48059..93b1bae399 100644 --- a/bolt-worker/bolt/worker/scheduling.py +++ b/bolt-worker/bolt/worker/scheduling.py @@ -44,7 +44,10 @@ def __eq__(self, other): return self.values == other.values @classmethod - def parse(cls, value, min_allowed, max_allowed, str_conversions={}): + def parse(cls, value, min_allowed, max_allowed, str_conversions=None): + if str_conversions is None: + str_conversions = {} + if isinstance(value, int): if value < min_allowed or value > max_allowed: raise ValueError( diff --git a/bolt-worker/bolt/worker/workers.py b/bolt-worker/bolt/worker/workers.py index 109813ae0c..8ddbee35e3 100644 --- a/bolt-worker/bolt/worker/workers.py +++ b/bolt-worker/bolt/worker/workers.py @@ -21,12 +21,15 @@ class Worker: def __init__( self, queues, - jobs_schedule=[], + jobs_schedule=None, max_processes=None, max_jobs_per_process=None, max_pending_per_process=10, stats_every=None, ): + if jobs_schedule is None: + jobs_schedule = [] + self.executor = ProcessPoolExecutor( max_workers=max_processes, max_tasks_per_child=max_jobs_per_process,