from pipeline import tasks
##Broker settings
BROKER_HOST = "localhost"
BROKER_PORT = 5672
BROKER_USER = "ltu"
BROKER_PASSWORD = "ltu"
BROKER_VHOST = "/"
#CELERY_RESULT_BACKEND = "amqp"
CELERY_IMPORTS = tuple(["pipeline.core.framework.delay_tasks"] +
  ["pipeline.tasks.%s" % lsModule for lsModule in tasks.__all__])

# configure backend to postgresql
CELERY_RESULT_BACKEND = "database"
CELERY_RESULT_DBURI = "postgresql://postgres:postgres@localhost/pipelinedemos"

## Worker settings

#Concurency: we only use one thread in order to have a correct evaluation
CELERYD_CONCURRENCY = 4

CELERYD_LOG_LEVEL = "INFO"
CELERY_ACKS_LATE = True

#no rate limit
CELERY_DISABLE_RATE_LIMITS = True
CELERY_AMQP_TASK_RESULT_EXPIRES = 18000  # 5 hours.
CELERY_ALWAYS_EAGER = False

~