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 [email protected].
To unsubscribe, please send an email to:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
