You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
returnidle_workers_infodefget_busy_workers(self) ->list[_WorkerInfo]:
""" Gets a WorkerInfo object for all busy workers. This uses Celery's API to poll active queues. Use the `busy_workers` property to avoid re-polling. Returns: list: List of WorkerInfo objects for all idle workers. """# TODO: Get busy workers# Seems to be a glitch getting busy workers in this version of Celery.# Fix planned for next release Feb or March.# This might work, but isn't yet:i=celery_app.control.inspect(timeout=10)
i.pattern=self.vc_key+"*"i.limit=1logger.debug(f"[magenta]Active: {i.active_queues()}")
busy_workers_info= []
returnbusy_workers_infoifnotbusy_workers:
returnbusy_workers_infoforworker, attributesinbusy_workers.items():
worker_vc_key=attributes[0]["routing_key"]
worker_info=_WorkerInfo(
name=worker,
host=str(worker).split("@")[1],
version_constraint_key=worker_vc_key,
compatible=worker_vc_key==self.vc_key,
)
busy_workers_info.append(worker_info)
returnbusy_workers_infoclassAppStatus:
def__init__(self, package_name: str):
26e24bda85ba6727e5cc66313769425c999e9de8
The text was updated successfully, but these errors were encountered:
Get busy workers
Seems to be a glitch getting busy workers in this version of Celery.
Fix planned for next release Feb or March.
This might work, but isn't yet:
proxima/src/proxima/app/checks.py
Line 138 in 18431a7
26e24bda85ba6727e5cc66313769425c999e9de8
The text was updated successfully, but these errors were encountered: