Method dequeue_rollout

tests/store/dummy_store.py:66–68 · view source on GitHub ↗

(self, worker_id: Optional[str] = None)

Source from the content-addressed store, hash-verified

64	return self.return_values["enqueue_many_rollouts"]
65
66	async def dequeue_rollout(self, worker_id: Optional[str] = None) -> Optional[AttemptedRollout]:
67	self.calls.append(("dequeue_rollout", (worker_id,), {}))
68	return self.return_values["dequeue_rollout"]
69
70	async def dequeue_many_rollouts(
71	self,

_async_taskFunction · 0.45

test_workers_endpoint_filter_and_sortFunction · 0.45

_run_server_side_operationsFunction · 0.45

_run_client_side_operationsFunction · 0.45

test_client_server_end_to_endFunction · 0.45

test_worker_status_transitions_via_attemptsFunction · 0.45

test_query_rollouts_by_statusFunction · 0.45

test_dequeue_rollout_skips_non_queuing_statusFunction · 0.45

test_fifo_orderingFunction · 0.45

test_pop_empty_queueFunction · 0.45

test_requeue_mechanismFunction · 0.45

test_enqueue_many_rollouts_preserves_orderFunction · 0.45

no outgoing calls

test_workers_endpoint_filter_and_sortFunction · 0.36

_run_server_side_operationsFunction · 0.36

_run_client_side_operationsFunction · 0.36

test_client_server_end_to_endFunction · 0.36

test_worker_status_transitions_via_attemptsFunction · 0.36

test_query_rollouts_by_statusFunction · 0.36

test_dequeue_rollout_skips_non_queuing_statusFunction · 0.36

test_fifo_orderingFunction · 0.36

test_pop_empty_queueFunction · 0.36

test_requeue_mechanismFunction · 0.36

test_enqueue_many_rollouts_preserves_orderFunction · 0.36

test_update_and_query_workersFunction · 0.36