Skip to content
Merged
6 changes: 4 additions & 2 deletions src/murfey/server/feedback.py
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,7 @@

import mrcfile
import numpy as np
from gemmi import cif
from gemmi import cif # type: ignore
from pipeliner.project_graph import ProjectGraph
from pipeliner.star_keys import GENERAL_BLOCK, JOB_COUNTER
from sqlalchemy import func
Expand Down Expand Up @@ -2390,7 +2390,9 @@ def feedback_callback(
) # should be True
except Exception:
logger.warning(
"Exception encountered in server RabbitMQ callback", exc_info=True
"Exception encountered in server-RabbitMQ callback for workflow "
f"'{message.get('register')}'",
exc_info=True,
)
if murfey.server._transport_object:
murfey.server._transport_object.transport.nack(header, requeue=False)
Expand Down
Loading
Loading