Build graphs to process streams. Now with Celery!