I think what you want is `ingest_csv.delay(...)` everywhere instead of the direct synchronous call?