add current item in forloop + global forloop reference (#2512)

skyvern/forge/sdk/workflow/models/block.py

@@ -198,6 +198,15 @@ class Block(BaseModel, abc.ABC):
                 )
 
         template_data[self.label] = block_reference_data
+
+        # inject the forloop metadata as global variables
+        if "current_index" in block_reference_data:
+            template_data["current_index"] = block_reference_data["current_index"]
+        if "current_item" in block_reference_data:
+            template_data["current_item"] = block_reference_data["current_item"]
+        if "current_value" in block_reference_data:
+            template_data["current_value"] = block_reference_data["current_value"]
+
         return template.render(template_data)
 
     @classmethod
@@ -948,7 +957,9 @@ class ForLoopBlock(Block):
                 metadata: BlockMetadata = {
                     "current_index": loop_idx,
                     "current_value": loop_over_value,
+                    "current_item": loop_over_value,
                 }
+                workflow_run_context.update_block_metadata(self.label, metadata)
                 workflow_run_context.update_block_metadata(loop_block.label, metadata)
 
                 original_loop_block = loop_block

skyvern/forge/sdk/workflow/models/parameter.py

@@ -8,6 +8,8 @@ from pydantic import BaseModel, ConfigDict, Field
 
 from skyvern.exceptions import InvalidWorkflowParameter
 
+RESERVED_PARAMETER_KEYS = ["current_item", "current_value", "current_index"]
+
 
 class ParameterType(StrEnum):
     WORKFLOW = "workflow"

skyvern/forge/sdk/workflow/service.py

@@ -61,6 +61,7 @@ from skyvern.forge.sdk.workflow.models.block import (
 )
 from skyvern.forge.sdk.workflow.models.parameter import (
     PARAMETER_TYPE,
+    RESERVED_PARAMETER_KEYS,
     AWSSecretParameter,
     BitwardenCreditCardDataParameter,
     BitwardenLoginCredentialParameter,
@@ -1450,6 +1451,12 @@ class WorkflowService:
                     reserved_keys=output_parameter_keys, parameter_keys=parameter_keys
                 )
 
+            if any(key in RESERVED_PARAMETER_KEYS for key in parameter_keys):
+                raise WorkflowDefinitionHasReservedParameterKeys(
+                    reserved_keys=RESERVED_PARAMETER_KEYS,
+                    parameter_keys=parameter_keys,
+                )
+
             # Create output parameters for all blocks
             block_output_parameters = await WorkflowService._create_all_output_parameters_for_workflow(
                 workflow_id=workflow.workflow_id,