script.py

defaults = {
   "image": "argopy:latest"
}

@argopy.container(**defaults)
def process_data(data_partition):
    do something with data

partitions = ['foo.csv', 'bar.csv']

with argopy.run as ap:
    for part in partitions:
        process_data(part)
    ap.run()
  

workflow.yaml

# Example of loops using DAGs
apiVersion: argoproj.io/v1alpha1
kind: Workflow
metadata:
  generateName: loops-dag-
spec:
  entrypoint: loops-dag
  templates:
  - name: loops-dag
    dag:
      tasks:
      - name: process_data
        template: process_data
        with_items:
          - foo.csv
          - bar.csv
    
  - name: process_data
    inputs:
      parameters:
      - name: partition
    container:
      image: argopy:latest
      command: [argopy-entrypoint]
      args: ["{{inputs.parameters.partition}}"]