tasks: use utcnow

invenio_jobs/jobs.py

@@ -73,7 +73,7 @@ def create(
                 task=task,
                 description=description,
                 title=title,
-                **attrs
+                **attrs,
             ),
         )
 

invenio_jobs/tasks.py

@@ -8,7 +8,7 @@
 """Tasks."""
 
 import traceback
-from datetime import datetime, timezone
+from datetime import datetime
 
 from celery import shared_task
 from invenio_db import db
@@ -32,27 +32,27 @@ def execute_run(self, run_id, kwargs=None):
     """Execute and manage a run state and task."""
     run = Run.query.filter_by(id=run_id).one_or_none()
     task = current_jobs.registry.get(run.job.task).task
-    update_run(run, status=RunStatusEnum.RUNNING, started_at=datetime.now(timezone.utc))
+    update_run(run, status=RunStatusEnum.RUNNING, started_at=datetime.utcnow())
     try:
         result = task.apply(kwargs=run.args, throw=True)
     except SystemExit as e:
         update_run(
             run,
             status=RunStatusEnum.CANCELLED,
-            finished_at=datetime.now(timezone.utc),
+            finished_at=datetime.utcnow(),
         )
         raise e
     except Exception as e:
         update_run(
             run,
             status=RunStatusEnum.FAILED,
-            finished_at=datetime.now(timezone.utc),
+            finished_at=datetime.utcnow(),
             message=f"{e.__class__.__name__}: {str(e)}\n{traceback.format_exc()}",
         )
         return
 
     update_run(
         run,
         status=RunStatusEnum.SUCCESS,
-        finished_at=datetime.now(timezone.utc),
+        finished_at=datetime.utcnow(),
     )