def METHOD_NAME(self, fl_ctx, shareable, shared_fl_context, topic):
    try:
        with self.engine.lock:
            reply = self.engine.dispatch(topic=topic, request=shareable, fl_ctx=fl_ctx)
    except Exception:
        self.logger.info("Could not connect to server runner process - asked client to end the run")
        reply = make_reply(ReturnCode.COMMUNICATION_ERROR)
    return reply