hh

SYS/pipeline.py

@@ -1903,31 +1903,31 @@ class PipelineExecutor:
                     else:
                         cmd_list = []
 
-                        # IMPORTANT: Put selected row args *before* source_args.
-                        # Rationale: The cmdlet argument parser treats the *first* unknown
-                        # token as a positional value (e.g., URL). If `source_args`
-                        # contain unknown flags (like -provider which download-file does
-                        # not declare), they could be misinterpreted as the positional
-                        # URL argument and cause attempts to download strings like
-                        # "-provider" (which is invalid). By placing selection args
-                        # first we ensure the intended URL/selection token is parsed
-                        # as the positional URL and avoid this class of parsing errors.
-                        expanded_stage: List[str] = cmd_list + selected_row_args + source_args
+                    # IMPORTANT: Put selected row args *before* source_args.
+                    # Rationale: The cmdlet argument parser treats the *first* unknown
+                    # token as a positional value (e.g., URL). If `source_args`
+                    # contain unknown flags (like -provider which download-file does
+                    # not declare), they could be misinterpreted as the positional
+                    # URL argument and cause attempts to download strings like
+                    # "-provider" (which is invalid). By placing selection args
+                    # first we ensure the intended URL/selection token is parsed
+                    # as the positional URL and avoid this class of parsing errors.
+                    expanded_stage: List[str] = cmd_list + selected_row_args + source_args
 
-                        if first_stage_had_extra_args and stages:
-                            expanded_stage += stages[0]
-                            stages[0] = expanded_stage
-                        else:
-                            stages.insert(0, expanded_stage)
+                    if first_stage_had_extra_args and stages:
+                        expanded_stage += stages[0]
+                        stages[0] = expanded_stage
+                    else:
+                        stages.insert(0, expanded_stage)
 
-                        if pipeline_session and worker_manager:
-                            try:
-                                worker_manager.log_step(
-                                    pipeline_session.worker_id,
-                                    f"@N expansion: {source_cmd} + selected_args={selected_row_args} + source_args={source_args}",
-                                )
-                            except Exception:
-                                logger.exception("Failed to record pipeline log step for @N expansion (pipeline_session=%r)", getattr(pipeline_session, 'worker_id', None))
+                    if pipeline_session and worker_manager:
+                        try:
+                            worker_manager.log_step(
+                                pipeline_session.worker_id,
+                                f"@N expansion: {source_cmd} + selected_args={selected_row_args} + source_args={source_args}",
+                            )
+                        except Exception:
+                            logger.exception("Failed to record pipeline log step for @N expansion (pipeline_session=%r)", getattr(pipeline_session, 'worker_id', None))
 
             stage_table = None
             try: