diff --git a/orbiter_translations/__init__.py b/orbiter_translations/__init__.py index 64998d8..f833df0 100644 --- a/orbiter_translations/__init__.py +++ b/orbiter_translations/__init__.py @@ -1,3 +1,3 @@ -__version__ = "0.5.0" +__version__ = "0.5.1" version = __version__ diff --git a/tests/autosys/demo/workflow/demo.jil b/tests/autosys/demo/workflow/demo.jil new file mode 100644 index 0000000..ae2b5d8 --- /dev/null +++ b/tests/autosys/demo/workflow/demo.jil @@ -0,0 +1,6 @@ +insert_job: foo.job +job_type: CMD +command: "C:\\ldhe\\cxl\\TidalDB\\startApp.cmd" "arg1" "arg2" "arg3" +machine: bar +owner: foo@bar.com +description: "Foo Job" diff --git a/tests/autosys/jil_demo_test.py b/tests/autosys/jil_demo_test.py new file mode 100644 index 0000000..ed5ad79 --- /dev/null +++ b/tests/autosys/jil_demo_test.py @@ -0,0 +1,12 @@ +from orbiter.objects.operators.ssh import OrbiterSSHOperator + +from orbiter_translations.autosys.jil_demo import translation_ruleset + + +def test_autosys_demo(project_root): + actual = translation_ruleset.translate_fn( + translation_ruleset, (project_root / "tests/autosys/demo/workflow/") + ) + assert list(actual.dags.keys()) == ["foo_job"] + assert sorted(list(actual.dags["foo_job"].tasks.keys())) == sorted(["foo_job",]) + assert isinstance(actual.dags["foo_job"].tasks["foo_job"], OrbiterSSHOperator)