GitHub user devmdr created a discussion: No cleaning of the Celery (RabbitMQ) 
queue

Hi,

I am using Superset version 5.0.0rc2 with Celery to schedule reports. Broker is 
RabbitMQ 4.1.1

Everything works as expected, but I noticed that queue is not being cleared. 
Messages contain something like:
```
{"task_id": "d8d3b05f-7a37-49bd-b118-55638cdcf282", "status": "SUCCESS", 
"result": null, "traceback": null, "children": []}
```

What to do to ensure that the queue is cleaned regularly?

Celery config is:

```
class CeleryConfig(object):
    broker_url = 'amqp://....'
    imports = ('superset.sql_lab', 'superset.tasks', 
'superset.tasks.scheduler', )
    result_backend = 'rpc://....'
    worker_prefetch_multiplier = 1
    task_acks_late = True
    task_soft_time_limit = 600 
    task_time_limit = 900      
    beat_schedule = {
        'reports.scheduler': {
            'task': 'reports.scheduler',
            'schedule': crontab(minute='*', hour='*'),
        },
        'reports.prune_log': {
            'task': 'reports.prune_log',
            'schedule': crontab(minute=0, hour=0),
        },
    }
```

GitHub link: https://github.com/apache/superset/discussions/34578

----
This is an automatically sent email for notifications@superset.apache.org.
To unsubscribe, please send an email to: 
notifications-unsubscr...@superset.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscr...@superset.apache.org
For additional commands, e-mail: notifications-h...@superset.apache.org

Reply via email to