Problem with testing bulk inserts with Task.async_stream

I add caller: parent option but it still gives me the same error.