Skip to content

Commit dc980b5

Browse files
committed
Remove RQ dependency
1 parent cf2e61b commit dc980b5

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

scheduler/redis_models/job.py

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -217,7 +217,8 @@ def create(
217217
if name is not None and JobModel.exists(name, connection=connection):
218218
raise ValueError(f"Job with name {name} already exists")
219219
if name is None:
220-
name = f"{queue_name}:{scheduled_task_id or ''}:{utils.utcnow().strftime("%Y%m%d%H%M%S%f")}"
220+
date_str = utils.utcnow().strftime("%Y%m%d%H%M%S%f")
221+
name = f"{queue_name}:{scheduled_task_id or ''}:{date_str}"
221222

222223
if inspect.ismethod(func):
223224
_func_name = func.__name__

0 commit comments

Comments
 (0)