use celery from scheduler events
accept on ly json as serializer in celery
add locking to scheduler
move locks to locks directory
celery
destroy and raise after every scheduler task
conn -> db
Cleanup in Celery