Skip to content

Commit

Permalink
Log the creation of a worker task thread (#1676)
Browse files Browse the repository at this point in the history
Right now the completion of a worker task thread is logged, but the
commencement of it (with any useful contextual information) is not,
which makes it difficult to follow the journey of particular failing
record imports.
  • Loading branch information
andrewpollock authored Oct 3, 2023
1 parent 5765f12 commit 578b697
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions docker/worker/worker.py
Original file line number Diff line number Diff line change
Expand Up @@ -617,6 +617,7 @@ def process_task(ack_id, message):
target=self._do_process_task,
args=(subscriber, subscription, ack_id, message, done_event),
daemon=True)
logging.info('Creating task thread for %s', message)
thread.start()

done = done_event.wait(timeout=MAX_LEASE_DURATION)
Expand Down

0 comments on commit 578b697

Please sign in to comment.