Fixed test

Signed-off-by: Kevin Su <[email protected]>
flyteorg · Oct 18, 2021 · 5aa98e6 · 5aa98e6
1 parent 21b6406
commit 5aa98e6
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 4 deletions.
diff --git a/flytekit/remote/remote.py b/flytekit/remote/remote.py
@@ -889,7 +889,6 @@ def _(
         task_identifiers_dict = None
         for node in entity.nodes:
             try:
-                print(resolved_identifiers.version)
                 task_identifiers_dict = deepcopy(resolved_identifiers_dict)
                 task_identifiers_dict["name"] = node.flyte_entity.name
                 self.fetch_task(**task_identifiers_dict)

diff --git a/tests/flytekit/integration/remote/test_remote.py b/tests/flytekit/integration/remote/test_remote.py
@@ -285,14 +285,13 @@ def test_execute_joblib_workflow(flyteclient, flyte_workflows_register, flyte_re
     assert output_obj == input_obj
 
 
-def test_execute_with_default_launch_plan(flyteclient, flyte_remote_env):
+def test_execute_with_default_launch_plan(flyteclient, flyte_workflows_register, flyte_remote_env):
     from mock_flyte_repo.workflows.basic.list_float_wf import my_wf
 
     my_wf._name = my_wf.name.replace("mock_flyte_repo.", "")
     remote = FlyteRemote.from_config(PROJECT, "development")
     xs: typing.List[float] = [42.24, 999.1, 0.0001]
-    version = uuid.uuid4().hex[:30] + str(int(time.time()))
-    execution = remote.execute(my_wf, version=version, inputs={"xs": xs}, wait=True)
+    execution = remote.execute(my_wf, inputs={"xs": xs}, wait=True)
     assert execution.outputs["o0"] == "[42.24, 999.1, 0.0001]"