[2026-04-20 02:40:13] INFO Successfully acknowledged task via NATS: $JS.ACK.job_1325.job-1325-consumer.1.1.1.1776667195632992406.0 [2026-04-20 02:40:13] INFO Cleaned up NATS resources for job 1325 [2026-04-20 02:40:13] INFO Deleted NATS stream job_1325 for job '1325' [2026-04-20 02:40:13] INFO Deleted NATS consumer job-1325-consumer for job '1325' [2026-04-20 02:40:13] INFO Finalizing NATS consumer job-1325-consumer before deletion (delivered=1 ack_floor=0 num_pending=0 num_ack_pending=1 num_redelivered=0) [2026-04-20 02:40:13] INFO Cleaned up Redis state for job 1325 [2026-04-20 02:40:13] INFO is_complete()=True after stage='results' update; firing cleanup. Stages: collect=100.0% SUCCESS, process=100.0% SUCCESS, results=100.0% SUCCESS [2026-04-20 02:40:13] INFO Job 1325 throughput: elapsed=0m 18s, processed=1/1, rate=3.3 imgs/min, ETA=0m 00s [2026-04-20 02:40:13] INFO Updated job 1325 progress in stage 'results' to 100.0% [2026-04-20 02:40:13] INFO Successfully saved results for job 1325 [2026-04-20 02:40:13] INFO Saved results from pipeline #3 "Quebec & Vermont moths" (quebec_vermont_moths_2023) v1 in 9.97 seconds [2026-04-20 02:40:12] INFO Creating detection images in sub-task fbfaece9-59bd-4b2c-809a-874a8205e665 [2026-04-20 02:40:12] INFO Updated the determination of 5 occurrences, left 65 unchanged [2026-04-20 02:40:09] INFO Updated 0 detections with occurrences [2026-04-20 02:40:09] INFO Created 0 new occurrences [2026-04-20 02:40:09] INFO Determining occurrences for 70 detections for source image 6238057 [2026-04-20 02:40:09] INFO Created 129 new classifications, updated 6 existing classifications for 70 detections. [2026-04-20 02:40:04] INFO Created 0 new detections, updated 70 existing detections, for 1 source image(s) [2026-04-20 02:40:03] INFO Algorithms registered for pipeline: fasterrcnn_mobilenet_for_ami_moth_traps_2023, fasterrcnn_for_ami_moth_traps_2023, moth_nonmoth_classifier, quebec_vermont_species_classifier, quebec_vermont_species_classifier_apr_2024 [2026-04-20 02:40:03] INFO Saving results from pipeline quebec_vermont_moths_2023 [2026-04-20 02:40:03] INFO Job 1325 progress: 1/1 images processed (100.0%), 0 remaining, 0 failed, 1 just processed [2026-04-20 02:40:03] INFO Processing pipeline result for job 1325, reply_subject: $JS.ACK.job_1325.job-1325-consumer.1.1.1.1776667195632992406.0 [2026-04-20 02:40:03] INFO Job 1325 throughput: elapsed=0m 07s, processed=1/1, rate=7.5 imgs/min, ETA=0m 00s [2026-04-20 02:40:03] INFO Updated job 1325 progress in stage 'process' to 100.0% [2026-04-20 02:40:02] INFO Queued pipeline result: task_id=9a592d31-3133-424e-b1b1-c2540a7079cb, reply_subject=$JS.ACK.job_1325.job-1325-consumer.1.1.1.1776667195632992406.0, user=antenna+processingservice-01@insectai.org, token_id=389306fc… [2026-04-20 02:39:57] INFO Tasks fetched: requested=16, delivered=1, user=antenna+processingservice-01@insectai.org, token_id=389306fc… [2026-04-20 02:39:55] INFO Waiting for workers to pick up tasks for pipeline 'quebec_vermont_moths_2023' (1/1 online recently) [2026-04-20 02:39:55] INFO Successfully queued 1/1 images to stream for job '1325' [2026-04-20 02:39:55] INFO Created NATS consumer job-1325-consumer (max_deliver=2, ack_wait=30.0s, max_ack_pending=1000, deliver_policy=all, ack_policy=explicit) [2026-04-20 02:39:55] INFO Created NATS stream job_1325 [2026-04-20 02:39:55] INFO Initialized task state tracking for 1 images [2026-04-20 02:39:55] INFO Queuing 1 images to NATS stream for job '1325' [2026-04-20 02:39:55] INFO Changing status of job 1325 from PENDING to STARTED [2026-04-20 02:39:55] INFO Running job #1325 "Capture #6238057" (PENDING)
