Commit d8e147a9 authored by Wout De Nolf's avatar Wout De Nolf
Browse files

test workflow events

parent 66288deb
Pipeline #69151 failed with stages
in 54 seconds
import pytest
from ewoksdask import execute_graph
from ewokscore.tests.test_workflow_events import fetch_events
from ewokscore.tests.test_workflow_events import run_succesfull_workfow
from ewokscore.tests.test_workflow_events import run_failed_workfow
from ewokscore.tests.test_workflow_events import assert_succesfull_workfow_events
from ewokscore.tests.test_workflow_events import assert_failed_workfow_events
@pytest.mark.parametrize("scheduler", (None, "multithreading", "multiprocessing"))
def test_succesfull_workfow(scheduler, tmpdir):
uri = run_succesfull_workfow(tmpdir, execute_graph, scheduler=scheduler)
events = fetch_events(uri, 10)
assert_succesfull_workfow_events(events)
@pytest.mark.parametrize("scheduler", (None, "multithreading", "multiprocessing"))
def test_failed_workfow(scheduler, tmpdir):
uri = run_failed_workfow(tmpdir, execute_graph, scheduler=scheduler)
events = fetch_events(uri, 8)
assert_failed_workfow_events(events)
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment