skorotkiewicz/rDrama
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Add more Cron diagnostic logging.

Browse source
This commit is contained in:
Ben Rog-Wilhelm 2023-04-22 04:34:05 -05:00
parent 6f2e2243b2
commit b4fecddf7b
1 changed files with 8 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

9
files/commands/cron.py
View file

@ -34,6 +34,10 @@ def cron_app_worker():
''' '''
The "worker" process task. This actually executes tasks. The "worker" process task. This actually executes tasks.
''' '''
# someday we'll clean this up further, for now I need debug info
logging.basicConfig(level=logging.INFO)
logging.info("Starting scheduler worker process") logging.info("Starting scheduler worker process")
while True: while True:
try: try:
@ -114,16 +118,19 @@ def _run_tasks(db_session_factory: scoped_session):
db.begin() db.begin()
run: RepeatableTaskRun = task.run(db, task.run_time_last_or_created_utc) run: RepeatableTaskRun = task.run(db, task.run_time_last_or_created_utc)
task_debug_identifier = f"(ID {run.task_id}:{task.label}, run ID {run.id})"
logging.info(f"Running task {task_debug_identifier}")
if run.exception: if run.exception:
# TODO: collect errors somewhere other than just here and in the # TODO: collect errors somewhere other than just here and in the
# task run object itself (see #220). # task run object itself (see #220).
logging.exception( logging.exception(
f"Exception running task (ID {run.task_id}, run ID {run.id})", f"Exception running task {task_debug_identifier}",
exc_info=run.exception exc_info=run.exception
) )
db.rollback() db.rollback()
else: else:
db.commit() db.commit()
logging.info(f"Finished task {task_debug_identifier}")
with _acquire_lock_exclusive(db, RepeatableTask.__tablename__): with _acquire_lock_exclusive(db, RepeatableTask.__tablename__):
task.run_state_enum = ScheduledTaskState.WAITING task.run_state_enum = ScheduledTaskState.WAITING