test: Add missing integration pattern test for ECS Task

Author: nicolaei

tests/unit/test_compute_steps.py

@@ -101,35 +101,71 @@ def test_batch_submit_job_step_creation():
 
 
 @patch.object(boto3.session.Session, 'region_name', 'us-east-1')
-def test_ecs_run_task_step_creation():
-    step = EcsRunTaskStep('Ecs Job', wait_for_completion=False)
+@pytest.mark.parametrize(
+    ("task_kwargs",),
+    [
+        ({},),
+        ({
+            "integration_pattern": IntegrationPattern.WaitForCompletion,
+            "wait_for_completion": False,
+        },),
+    ]
+)
+def test_ecs_run_task_with_wait_for_completion(task_kwargs):
+    step = EcsRunTaskStep('ECS Job', **task_kwargs)
+
     assert step.to_dict() == {
         'Type': 'Task',
-        'Resource': 'arn:aws:states:::ecs:runTask',
+        'Resource': 'arn:aws:states:::ecs:runTask.sync',
         'End': True
     }
 
-    step = EcsRunTaskStep('Ecs Job',
-                          integration_pattern=IntegrationPattern.WaitForTaskToken,
-                          wait_for_completion=False)
+
+@patch.object(boto3.session.Session, 'region_name', 'us-east-1')
+@pytest.mark.parametrize(
+    ("task_kwargs",),
+    [
+        ({
+            "integration_pattern": IntegrationPattern.WaitForTaskToken,
+            "wait_for_completion": False,
+        },),
+    ]
+)
+def test_ecs_run_task_with_wait_for_task_token(task_kwargs):
+    step = EcsRunTaskStep('ECS Job', **task_kwargs)
+
     assert step.to_dict() == {
         'Type': 'Task',
         'Resource': 'arn:aws:states:::ecs:runTask.waitForTaskToken',
         'End': True
     }
 
-    step = EcsRunTaskStep('Ecs Job', parameters={
-        'TaskDefinition': 'Task'
-    })
+
+@patch.object(boto3.session.Session, 'region_name', 'us-east-1')
+@pytest.mark.parametrize(
+    ("task_kwargs",),
+    [
+        ({
+            "wait_for_completion": False,
+        },),
+        ({
+            "integration_pattern": IntegrationPattern.CallAndContinue,
+            "wait_for_completion": False,
+        },)
+    ]
+)
+def test_ecs_run_task_with_call_and_continue(task_kwargs):
+    step = EcsRunTaskStep('ECS Job', **task_kwargs)
+
     assert step.to_dict() == {
         'Type': 'Task',
-        'Resource': 'arn:aws:states:::ecs:runTask.sync',
-        'Parameters': {
-            'TaskDefinition': 'Task'
-        },
+        'Resource': 'arn:aws:states:::ecs:runTask',
         'End': True
     }
 
+
+@patch.object(boto3.session.Session, 'region_name', 'us-east-1')
+def test_ecs_run_task_with_conflicting_arguments():
     with pytest.raises(ValueError):
         step = EcsRunTaskStep('Ecs Job',
                               wait_for_completion=True,