def test_attempt_to_launch_runs_no_queued(instance, grpc_server_registry):
    create_run(instance, run_id='queued-run', status=PipelineRunStatus.STARTED)
    create_run(instance, run_id='non-queued-run', status=PipelineRunStatus.NOT_STARTED)
    coordinator = QueuedRunCoordinatorDaemon(interval_seconds=5, max_concurrent_runs=10)
    list(coordinator.run_iteration(instance, grpc_server_registry))
    assert (instance.run_launcher.queue() == [])
def test_attempt_to_launch_runs_no_queued(instance, grpc_server_registry):
    create_run(instance, run_id='queued-run', status=PipelineRunStatus.STARTED)
    create_run(instance, run_id='non-queued-run', status=PipelineRunStatus.NOT_STARTED)
    coordinator = QueuedRunCoordinatorDaemon(interval_seconds=5, max_concurrent_runs=10)
    list(coordinator.run_iteration(instance, grpc_server_registry))
    assert (instance.run_launcher.queue() == [])