Writing your own remote control commands Remote control commands are registered in the control panel and they take a single argument: the current ControlDispatch instance. From there you have access connection: from celery.worker.control import Panel @Panel.register def reset_connection(panel): panel.logger.critical("Connection reset by remote control.") panel.listener.reset_connection() return control.ControlDispatch(logger=None, hostname=None, listener=None) Execute worker control panel commands. class Panel(logger, listener, hostname=None) data = {'stats': , 'revoke':

Writing your own remote control commands Remote control commands are registered in the control panel and they take a single argu- ment: the current ControlDispatch instance. From there you have access connection: from celery.worker.control import Panel @Panel.register def reset_connection(panel): panel.logger.critical("Connection reset by remote control.") panel.listener.reset_connection() return {"ok": control.ControlDispatch(logger=None, hostname=None, listener=None) Execute worker control panel commands. class Panel(logger, listener, hostname=None) data = {‘stats’: , ‘revoke’:

Writing your own remote control commands Remote control commands are registered in the control panel and they take a single argu- ment: the current ControlDispatch instance. From there you have access connection: from celery.worker.control import Panel @Panel.register def reset_connection(panel): panel.logger.critical("Connection reset by remote control.") panel.listener.reset_connection() return {"ok": control.Panel.register(): 9.8. 1.0.3 135 Celery Documentation, Release 2.0.3 (stable) from celery.task.control import Panel @Panel.register def reset_broker_connection(panel, **kwargs): panel.listener

Writing your own remote control commands Remote control commands are registered in the control panel and they take a single argument: the current ControlDispatch instance. From there you have access connection: from celery.worker.control import Panel @Panel.register def reset_connection(panel): panel.logger.critical("Connection reset by remote control.") panel.listener.reset_connection() return is done using celery.worker.control.Panel.register(): from celery.task.control import Panel @Panel.register def reset_broker_connection(panel, **kwargs): panel.listener.reset_connection() return

Writing your own remote control commands Remote control commands are registered in the control panel and they take a single argument: the current ControlDispatch instance. From there you have access connection: from celery.worker.control import Panel @Panel.register def reset_connection(panel): panel.logger.critical("Connection reset by remote control.") panel.consumer.reset_connection() return {"ok": command is done using celery.worker.control.Panel.register(): from celery.task.control import Panel @Panel.register def reset_broker_connection(panel, **kwargs): panel.consumer.reset_connection() return {"ok":

Writing your own remote control commands Remote control commands are registered in the control panel and they take a single argument: the current ControlDispatch instance. From there you have access connection: from celery.worker.control import Panel @Panel.register def reset_connection(panel): panel.logger.critical("Connection reset by remote control.") panel.consumer.reset_connection() return {"ok": command is done using celery.worker.control.Panel.register(): from celery.task.control import Panel @Panel.register def reset_broker_connection(panel, **kwargs): panel.consumer.reset_connection() return {"ok":

Writing your own remote control commands Remote control commands are registered in the control panel and they take a single argument: the current ControlDispatch instance. From there you have access connection: from celery.worker.control import Panel @Panel.register def reset_connection(panel): panel.logger.critical("Connection reset by remote control.") panel.consumer.reset_connection() return is done using celery.worker.control.Panel.register(): from celery.task.control import Panel @Panel.register def reset_broker_connection(panel, **kwargs): panel.consumer.reset_connection() return

Writing your own remote control commands Remote control commands are registered in the control panel and they take a single argument: the current ControlDispatch instance. From there you have access connection: from celery.worker.control import Panel @Panel.register def reset_connection(panel): panel.logger.critical("Connection reset by remote control.") panel.consumer.reset_connection() return is done using celery.worker.control.Panel.register(): from celery.task.control import Panel @Panel.register def reset_broker_connection(panel, **kwargs): panel.consumer.reset_connection() return

Writing your own remote control commands Remote control commands are registered in the control panel and they take a single argument: the current ControlDispatch instance. From there you have access connection: from celery.worker.control import Panel @Panel.register def reset_connection(panel): panel.logger.critical("Connection reset by remote control.") panel.consumer.reset_connection() return {"ok": command is done using celery.worker.control.Panel.register(): from celery.task.control import Panel @Panel.register def reset_broker_connection(panel, **kwargs): panel.consumer.reset_connection() return {"ok":

Writing your own remote control commands Remote control commands are registered in the control panel and they take a single argument: the current ControlDispatch instance. From there you have access connection: from celery.worker.control import Panel @Panel.register def reset_connection(panel): panel.logger.critical("Connection reset by remote control.") panel.consumer.reset_connection() return {"ok": command is done using celery.worker.control.Panel.register(): from celery.task.control import Panel @Panel.register def reset_broker_connection(panel, **kwargs): panel.consumer.reset_connection() return {"ok":