celery + cleanup via celery + initial collector support