ewokscore.tests.test_workflow_events#

Functions

assert_failed_workfow_events(events)

assert_succesfull_workfow_events(events)

fetch_events(database, nevents)

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

run_failed_workfow(database, execute_graph)

run_succesfull_workfow(database, execute_graph)

sqlite_path(tmp_path)

test_changing_handlers(sqlite_path)

test_changing_handlers_parallel(sqlite_path)

test_failed_workfow(sqlite_path)

test_succesfull_workfow(sqlite_path)

Classes

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