@task(queue='ingest')
def ingest (token_name, channel_name, resolution, data_url, file_format, file_type):

  try:
    ingest_data = IngestData(token_name, channel_name, resolution, data_url, file_format, file_type)
    ingest_data.ingest()
  except Exception, e:
    logger.error("Error in ingest. {}".format(e))
Call the remote ingest function here
dataset/ETHPy150Open neurodata/ndstore/django/ocpca/tasks.py/ingest