Source code for ewoksppf.tests.test_ppf_workflow1

from ewokscore.tests.utils.results import assert_execute_graph_default_result

from ewoksppf import execute_graph



[docs]
def workflow1():
    nodes = [
        {
            "id": "Python Actor Test",
            "default_inputs": [{"name": "name", "value": "myname"}],
            "task_type": "ppfmethod",
            "task_identifier": "ewoksppf.tests.test_ppf_actors.pythonActorTest.run",
        },
    ]

    links = []

    graph = {
        "graph": {"id": "workflow1"},
        "links": links,
        "nodes": nodes,
    }

    expected_results = {
        "Python Actor Test": {"_ppfdict": {"name": "myname", "reply": "Hello myname!"}}
    }

    return graph, expected_results




[docs]
def test_workflow1(ppf_log_config, tmpdir):
    varinfo = {"root_uri": str(tmpdir)}
    graph, expected = workflow1()
    result = execute_graph(graph, varinfo=varinfo)
    assert_execute_graph_default_result(graph, result, expected, varinfo)