def METHOD_NAME(*args, sender: Consumer = None, **kwargs):
    logger.info(f"worker {sender.hostname} ready")
    queue = sender.hostname.split("_", maxsplit=1)[1]
    logger.info(f"Updating repositories inside {queue}")
    if settings.REPO_DOWNLOADER_ENABLED and queue == get_queue_name(DEFAULT_QUEUE):
        for task in PeriodicTask.objects.filter(
            enabled=True, queue=queue, task="intel_owl.tasks.update"
        ):
            config_pk = task.kwargs["config_pk"]
            logger.info(f"Updating {config_pk}")
            update(config_pk)