1 parent 74f7a75 commit dec9c5cCopy full SHA for dec9c5c
2 files changed
steady_queue/__init__.py
@@ -1,7 +1,7 @@
1
from datetime import timedelta
2
from typing import Optional
3
4
-VERSION = (0, 1, "0b5")
+VERSION = (0, 1, "0b6")
5
6
__version__ = ".".join(map(str, VERSION))
7
steady_queue/processes/worker.py
@@ -32,7 +32,7 @@ def poll(self) -> timedelta:
32
claimed_executions = self.claim_executions()
33
for execution in claimed_executions:
34
logger.info(
35
- "%(worker)s claimed job %(job_id)s %(task_name)s",
+ "%(worker)s claimed job %(job_id)s %(class_name)s",
36
{
37
"worker": self.name,
38
"job_id": execution.job_id,
0 commit comments