Skip to content

Commit 17180cd

Browse files
authored
This ack seems to have no business being here (#531)
1 parent 324f70b commit 17180cd

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

src/murfey/server/__init__.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2418,10 +2418,6 @@ def feedback_callback(header: dict, message: dict) -> None:
24182418
_transport_object.transport.nack(header, requeue=True)
24192419
return None
24202420
prom.preprocessed_movies.labels(processing_job=pid)
2421-
if message.get("job_parameters"):
2422-
if _transport_object:
2423-
_transport_object.transport.ack(header)
2424-
return None
24252421
if not murfey_db.exec(
24262422
select(db.AutoProcProgram).where(db.AutoProcProgram.pj_id == pid)
24272423
).all():

0 commit comments

Comments
 (0)