Skip to content
This repository has been archived by the owner on Oct 25, 2024. It is now read-only.

Commit

Permalink
Change module name
Browse files Browse the repository at this point in the history
  • Loading branch information
jaredoconnell committed Sep 15, 2023
1 parent 8fd8707 commit 2e49f46
Show file tree
Hide file tree
Showing 4 changed files with 10 additions and 10 deletions.
2 changes: 1 addition & 1 deletion .github/workflows/workflow.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -21,4 +21,4 @@ jobs:
needs: act
uses: arcalot/arcaflow-docsgen/.github/workflows/reusable_workflow.yaml@main
with:
plugin_path: "arcaflow_plugin_wait/wait_plugin.py"
plugin_path: "arcaflow_plugin_wait/arcaflow_plugin_wait.py"
2 changes: 1 addition & 1 deletion pyproject.toml
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ classifiers = [
]
homepage = "https://github.com/arcalot/arcaflow-plugin-wait"
packages = [
{ include="wait_plugin.py", from="./arcaflow_plugin_wait" },
{ include="arcaflow_plugin_wait.py", from="./arcaflow_plugin_wait" },
]

[tool.poetry.dependencies]
Expand Down
16 changes: 8 additions & 8 deletions tests/test_arcaflow_plugin_wait.py
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
from arcaflow_plugin_sdk import plugin, predefined_schemas

import time
import wait_plugin
import arcaflow_plugin_wait

WAIT_TIME = 0.1
SKIPPED_WAIT_TIME = 1.0
Expand All @@ -15,21 +15,21 @@ class WaitTest(unittest.TestCase):
@staticmethod
def test_serialization():
plugin.test_object_serialization(
wait_plugin.InputParams(
arcaflow_plugin_wait.InputParams(
WAIT_TIME
)
)

plugin.test_object_serialization(
wait_plugin.SuccessOutput(
arcaflow_plugin_wait.SuccessOutput(
"Waited {:0.2f} seconds after being scheduled to wait for"
" {} seconds.".format(WAIT_TIME, WAIT_TIME),
actual_wait_seconds=WAIT_TIME
)
)

plugin.test_object_serialization(
wait_plugin.ErrorOutput(
arcaflow_plugin_wait.ErrorOutput(
error="Aborted {:0.2f} seconds after being scheduled to wait"
" for {} seconds.".format(PREMATURE_TIME, WAIT_TIME),
actual_wait_seconds=PREMATURE_TIME
Expand All @@ -38,10 +38,10 @@ def test_serialization():

def test_functional(self):
# Test simple wait
input_params = wait_plugin.InputParams(
input_params = arcaflow_plugin_wait.InputParams(
seconds=WAIT_TIME
)
wait_step = wait_plugin.WaitStep()
wait_step = arcaflow_plugin_wait.WaitStep()
output_id, output_data = wait_step.wait(input_params)

self.assertEqual("success", output_id)
Expand All @@ -51,10 +51,10 @@ def test_functional(self):
" seconds.".format(output_data.actual_wait_seconds, WAIT_TIME)
)
# Test cancellation
input_params = wait_plugin.InputParams(
input_params = arcaflow_plugin_wait.InputParams(
seconds=SKIPPED_WAIT_TIME
)
wait_step = wait_plugin.WaitStep()
wait_step = arcaflow_plugin_wait.WaitStep()
wait_step.cancel_step(wait_step, predefined_schemas.cancelInput())
start_time = time.time()
output_id, output_data = wait_step.wait(input_params)
Expand Down

0 comments on commit 2e49f46

Please sign in to comment.