beginning implementation of queueing
correct import error
remove import
Project Restructuring for "do it all" worker
adding tasks retry and late_ack to the persist message function
celery config options
celer config cnahges for concurrency
trying async threads with celery task
concurrency raised for threading
testing eventlet
import change
pyes thread safe connection
elastic search thread safe
uncomment retry
es config
es config
pyes
eventlet
lower concurrency
up connection pool