Fix map tasks (flyteorg#429)

dolthub · Mar 24, 2021 · f458c65 · f458c65
1 parent d54b42f
commit f458c65
Showing 1 changed file with 2 additions and 18 deletions.
diff --git a/flytekit/bin/entrypoint.py b/flytekit/bin/entrypoint.py
@@ -411,28 +411,12 @@ def fast_execute_task_cmd(additional_distribution, dest_dir, task_execute_cmd):
     "resolver-args", type=_click.UNPROCESSED, nargs=-1,
 )
 def map_execute_task_cmd(
-    task_module,
-    task_name,
-    inputs,
-    output_prefix,
-    raw_output_data_prefix,
-    max_concurrency,
-    test,
-    resolver,
-    resolver_args,
+    inputs, output_prefix, raw_output_data_prefix, max_concurrency, test, resolver, resolver_args,
 ):
     _click.echo(_utils.get_version_message())
 
     _execute_map_task(
-        task_module,
-        task_name,
-        inputs,
-        output_prefix,
-        raw_output_data_prefix,
-        max_concurrency,
-        test,
-        resolver,
-        resolver_args,
+        inputs, output_prefix, raw_output_data_prefix, max_concurrency, test, resolver, resolver_args,
     )