INNER CODE UNIT · Python
listen_for_docker_events
ChrispyBacon-dev/DockFlare · dockflare-agent/app/main.py:511
def listen_for_docker_events(client, label_prefix, initial_scan=True):
thread_health_status[f"events_listener_{label_prefix.strip('.')}"] = "running"
if initial_scan:
logging.info("Performing one initial scan of running DockFlare containers...")
try:
for container in client.containers.list():
if is_dockflare_enabled(container.labels):
report_event_to_master("container_start", {
"id": container.id,
"name": container.name,
"labels": container.labels,
})
except Exception as e:
logging.error(f"Error during initial container scan: {e}")
logging.info(f"Listening for Docker events with prefix {label_prefix}...")
event_filters = {
"type": "container",