Searched defs:queue_ctx (Results 1 – 1 of 1) sorted by relevance
487 def _run_infeed(self, queue_ctx, session): argument506 def _run_outfeed(self, queue_ctx, session): argument