def test_priority_on_malformed_tag(instance, grpc_server_registry):
    create_run(instance, run_id='bad-pri-run', status=PipelineRunStatus.QUEUED, tags={PRIORITY_TAG: 'foobar'})
    coordinator = QueuedRunCoordinatorDaemon(interval_seconds=5, max_concurrent_runs=10)
    list(coordinator.run_iteration(instance, grpc_server_registry))
    assert (get_run_ids(instance.run_launcher.queue()) == ['bad-pri-run'])
def test_priority_on_malformed_tag(instance, grpc_server_registry):
    create_run(instance, run_id='bad-pri-run', status=PipelineRunStatus.QUEUED, tags={PRIORITY_TAG: 'foobar'})
    coordinator = QueuedRunCoordinatorDaemon(interval_seconds=5, max_concurrent_runs=10)
    list(coordinator.run_iteration(instance, grpc_server_registry))
    assert (get_run_ids(instance.run_launcher.queue()) == ['bad-pri-run'])