fix bucket

savingoyal · savingoyal · commit 7cf9522f6dc7 · 2024-02-09T15:31:06.000-07:00
diff --git a/metaflow/plugins/aws/step_functions/step_functions.py b/metaflow/plugins/aws/step_functions/step_functions.py
@@ -395,9 +395,11 @@ def _visit(node, workflow, exit_node=None):
                     # do...
                     .result_writer(
                         *(
-                            SFN_S3_DISTRIBUTED_MAP_OUTPUT_PATH.rsplit("/", 1)
+                            "s3://"
+                            + SFN_S3_DISTRIBUTED_MAP_OUTPUT_PATH[5:].split("/", 1)[0],
+                            SFN_S3_DISTRIBUTED_MAP_OUTPUT_PATH[5:].split("/", 1)[1]
                             if self.use_distributed_map
-                            else ()
+                            else (),
                         )
                     )
                     .output_path("$" if self.use_distributed_map else "$.[0]")

Original file line number	Diff line number	Diff line change
`@@ -395,9 +395,11 @@ def _visit(node, workflow, exit_node=None):`
`395`	`395`	`# do...`
`396`	`396`	`.result_writer(`
`397`	`397`	`*(`
`398`		`- SFN_S3_DISTRIBUTED_MAP_OUTPUT_PATH.rsplit("/", 1)`
	`398`	`+ "s3://"`
	`399`	`+ + SFN_S3_DISTRIBUTED_MAP_OUTPUT_PATH[5:].split("/", 1)[0],`
	`400`	`+ SFN_S3_DISTRIBUTED_MAP_OUTPUT_PATH[5:].split("/", 1)[1]`
`399`	`401`	`if self.use_distributed_map`
`400`		`- else ()`
	`402`	`+ else (),`
`401`	`403`	`)`
`402`	`404`	`)`
`403`	`405`	`.output_path("$" if self.use_distributed_map else "$.[0]")`