ewokscore.tests.test_workflow_events

Functions

assert_failed_workfow_events(events)

assert_succesfull_workfow_events(events)

fetch_events(uri, nevents)

Events are handled asynchronously so wait until we have the required nevents up to 3 seconds.

run_failed_workfow(tmpdir, execute_graph, ...)

run_succesfull_workfow(tmpdir, ...)

test_failed_workfow(tmpdir)

test_succesfull_workfow(tmpdir)

Classes

MyTask([inputs, varinfo, node_id, ...])

param inputs: