add missing associate jobs during message consumption

packages/syft/src/syft/service/queue/zmq_queue.py

@@ -577,6 +577,7 @@ def _run(self):
                         # Call Message Handler
                         try:
                             message = msg.pop()
+                            self.associate_job(message)
                             self.message_handler.handle_message(
                                 message=message,
                                 syft_worker_id=self.syft_worker_id,