Fix unit test for plugins

Signed-off-by: Yuvraj <[email protected]>
flyteorg · Oct 28, 2021 · e6deaa8 · e6deaa8
1 parent 8ee2cd2
commit e6deaa8
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/plugins/flytekit-kf-pytorch/tests/test_pytorch_task.py b/plugins/flytekit-kf-pytorch/tests/test_pytorch_task.py
@@ -5,7 +5,7 @@
 
 
 def test_pytorch_task():
-    @task(task_config=PyTorch(num_workers=10, per_replica_requests=Resources(cpu="1")), cache=True, cache_version="1")
+    @task(task_config=PyTorch(num_workers=10), cache=True, cache_version="1", requests=Resources(cpu="1"),)
     def my_pytorch_task(x: int, y: str) -> int:
         return x
 

diff --git a/plugins/flytekit-kf-tensorflow/tests/test_tensorflow_task.py b/plugins/flytekit-kf-tensorflow/tests/test_tensorflow_task.py
@@ -7,9 +7,10 @@
 def test_tensorflow_task():
     @task(
         task_config=TfJob(
-            num_workers=10, per_replica_requests=Resources(cpu="1"), num_ps_replicas=1, num_chief_replicas=1
+            num_workers=10,  num_ps_replicas=1, num_chief_replicas=1
         ),
         cache=True,
+        requests=Resources(cpu="1"),
         cache_version="1",
     )
     def my_tensorflow_task(x: int, y: str) -> int: