diff --git a/docker/package.json b/docker/package.json
index d068540..0876a71 100644
--- a/docker/package.json
+++ b/docker/package.json
@@ -1,6 +1,6 @@
 {
   "name": "okdp-examples",
-  "version": "1.0.0",
+  "version": "1.1.0",
   "description": "okdp-examples docker image",
   "repository": {
     "type": "git",
diff --git a/helm/okdp-examples/Chart.yaml b/helm/okdp-examples/Chart.yaml
index a2ff3a1..cc331c1 100644
--- a/helm/okdp-examples/Chart.yaml
+++ b/helm/okdp-examples/Chart.yaml
@@ -17,10 +17,10 @@
 apiVersion: v2
 type: application
 name: okdp-examples
-version: 1.1.0
+version: 1.1.1
 sources:
   - https://github.com/okdp/okdp-examples
-appVersion: "1.1.0"
+appVersion: "1.1.1"
 description: |
   A collection of hands-on examples, helper utilities, Jupyter notebooks, and data workflows 
   that showcases how to work with the OKDP Platform.
diff --git a/helm/okdp-examples/README.md b/helm/okdp-examples/README.md
index 08dcfb7..19ab3fb 100644
--- a/helm/okdp-examples/README.md
+++ b/helm/okdp-examples/README.md
@@ -1,6 +1,6 @@
 # okdp-examples
 
-![Version: 1.1.0](https://img.shields.io/badge/Version-1.1.0-informational?style=flat-square) ![Type: application](https://img.shields.io/badge/Type-application-informational?style=flat-square) ![AppVersion: 1.1.0](https://img.shields.io/badge/AppVersion-1.1.0-informational?style=flat-square)
+![Version: 1.1.1](https://img.shields.io/badge/Version-1.1.1-informational?style=flat-square) ![Type: application](https://img.shields.io/badge/Type-application-informational?style=flat-square) ![AppVersion: 1.1.1](https://img.shields.io/badge/AppVersion-1.1.1-informational?style=flat-square)
 
 A collection of hands-on examples, helper utilities, Jupyter notebooks, and data workflows
 that showcases how to work with the OKDP Platform.
@@ -19,37 +19,34 @@ that showcases how to work with the OKDP Platform.
 
 | Key | Type | Default | Description |
 |-----|------|---------|-------------|
-| affinity | object | `{}` |  |
-| commands.01-prepare_env.01-create-spark-event-log-dir | string | `"echo \"👉 Connect into S3\"\nmc alias set myminio $S3_ENDPOINT \"$S3_ACCESS_KEY\" \"$S3_SECRET_KEY\"\necho \"👉 MinIO alias configured successfully.\"\necho \"👉 Normalize the log directory $SPARK_EVENT_LOG_DIRECTORY\"\nno_scheme=\"${SPARK_EVENT_LOG_DIRECTORY#s3a://}\"\nno_scheme=\"${no_scheme%/}\"\nbucket=\"${no_scheme%%/*}\"\nprefix=\"${no_scheme#${bucket}}\"\nprefix=\"${prefix#/}\"\necho \"👉 Bucket: $bucket, Prefix: $prefix\"\necho \"👉 Create the bucket $bucket if not exist\"\nmc mb myminio/$bucket || true\necho \"👉 upload a zero-byte object to create the prefix: ${bucket}/${prefix}/.keep\"\nmc pipe \"myminio/${bucket}/${prefix}/.keep\" < /dev/null\necho \"✅ Spark events log directory $SPARK_EVENT_LOG_DIRECTORY successfully created.\";\n"` |  |
-| commands.02-nyc_trip."03-nyc-tripdata-trino-external-tables.sql" | string | `"trino --server ${TRINO_SERVER_URL} --insecure <<SQL\n  CREATE SCHEMA IF NOT EXISTS lakehouse.nyc_tripdata;\n\n  CREATE TABLE IF NOT EXISTS lakehouse.nyc_tripdata.yellow (\n    vendorid INT,\n    tpep_pickup_datetime TIMESTAMP,\n    tpep_dropoff_datetime TIMESTAMP,\n    passenger_count INT,\n    trip_distance DOUBLE,\n    ratecodeid INT,\n    store_and_fwd_flag VARCHAR,\n    pulocationid INT,\n    dolocationid INT,\n    payment_type INT,\n    fare_amount DOUBLE,\n    extra DOUBLE,\n    mta_tax DOUBLE,\n    tip_amount DOUBLE,\n    tolls_amount DOUBLE,\n    improvement_surcharge DOUBLE,\n    total_amount DOUBLE,\n    congestion_surcharge DOUBLE,\n    airport_fee DOUBLE,\n    cbd_congestion_fee DOUBLE,\n    month VARCHAR\n  )\n  WITH (\n    external_location = 's3a://${BUCKET}/${BUCKET_PREFIX}/yellow/',\n    format = 'PARQUET',\n    partitioned_by = ARRAY['month']\n  );\n\n  CREATE TABLE IF NOT EXISTS lakehouse.nyc_tripdata.green (\n    vendorid INT,\n    lpep_pickup_datetime TIMESTAMP,\n    lpep_dropoff_datetime TIMESTAMP,\n    store_and_fwd_flag VARCHAR,\n    ratecodeid INT,\n    pulocationid INT,\n    dolocationid INT,\n    passenger_count INT,\n    trip_distance DOUBLE,\n    fare_amount DOUBLE,\n    extra DOUBLE,\n    mta_tax DOUBLE,\n    tip_amount DOUBLE,\n    tolls_amount DOUBLE,\n    improvement_surcharge DOUBLE,\n    total_amount DOUBLE,\n    payment_type INT,\n    trip_type INT,\n    congestion_surcharge DOUBLE,\n    cbd_congestion_fee DOUBLE,\n    month VARCHAR\n  )\n  WITH (\n    external_location = 's3a://${BUCKET}/${BUCKET_PREFIX}/green/',\n    format = 'PARQUET',\n    partitioned_by = ARRAY['month']\n  );\n\n  CREATE TABLE IF NOT EXISTS lakehouse.nyc_tripdata.fhv (\n    dispatching_base_num VARCHAR,\n    pickup_datetime TIMESTAMP,\n    dropoff_datetime TIMESTAMP,\n    pulocationid INT,\n    dolocationid INT,\n    sr_flag INT,\n    affiliated_base_number VARCHAR,\n    month VARCHAR\n  )\n  WITH (\n    external_location = 's3a://${BUCKET}/${BUCKET_PREFIX}/fhv/',\n    format = 'PARQUET',\n    partitioned_by = ARRAY['month']\n  );\nSQL\n"` |  |
-| commands.02-nyc_trip.01-download-nyc-tripdata | string | `"mkdir -p /data/tripdata\ncd /data/tripdata;\nfor dataset in yellow green fhv; do\n  for month in 01 02 03; do\n    file=\"${dataset}_tripdata_2025-${month}.parquet\";\n    url=\"$DATA_URL/$file\";\n    echo \"→ $url\";\n    if curl -fsSLO \"$url\"; then\n      echo \"✅ Downloaded: $file\";\n    else\n      echo \"⚠️ Missing: $file\";\n    fi;\n  done;\ndone;\nls -lh /data/tripdata\necho \"✅ All downloads complete.\";\n"` |  |
-| commands.02-nyc_trip.02-upload-nyc-tripdata-into-s3 | string | `"echo \"👉 Connect into S3\"\nmc alias set myminio $S3_ENDPOINT \"$S3_ACCESS_KEY\" \"$S3_SECRET_KEY\"\necho \"👉 MinIO alias configured successfully.\"\n### echo \"👉 Clean the examples folder if it exists\"\n### mc rm --recursive --force myminio/$BUCKET/examples\necho \"👉 Create the bucket if not exist\"\nmc mb myminio/$BUCKET || true\necho \"👉 Upload sample files into the correct folders\"\n\nfor category in yellow green fhv; do\n  echo \"🚀 Processing category: $category\"\n  for file in /data/tripdata/${category}_*.parquet; do\n    [ -e \"$file\" ] || continue  # skip if no files match\n    month=$(basename \"$file\" | sed -E 's/.*_([0-9]{4}-[0-9]{2})\\.parquet/\\1/')\n    echo \"📦 Uploading $file → ${BUCKET_PREFIX}/$category/month=$month/\"\n    mc cp \"$file\" \"myminio/$BUCKET/${BUCKET_PREFIX}/$category/month=$month/\"\n  done\ndone\n\necho \"👉 Verify bucket structure\"\nmc tree myminio/$BUCKET\nmc ls --recursive myminio/$BUCKET\n"` |  |
-| commands.02-nyc_trip.04-nyc-tripdata-trino-synchronize-partitions | string | `"trino --server ${TRINO_SERVER_URL} --insecure <<SQL\n  CALL lakehouse.system.sync_partition_metadata(\n    schema_name => 'nyc_tripdata',\n    table_name => 'yellow',\n    mode => 'ADD'\n  );\n  CALL lakehouse.system.sync_partition_metadata(\n    schema_name => 'nyc_tripdata',\n    table_name => 'green',\n    mode => 'ADD'\n  );\n  CALL lakehouse.system.sync_partition_metadata(\n    schema_name => 'nyc_tripdata',\n    table_name => 'fhv',\n    mode => 'ADD'\n  );\nSQL\n"` |  |
-| commands.02-nyc_trip.05-nyc-tripdata-trino-validate | string | `"trino --server ${TRINO_SERVER_URL} --insecure <<SQL\n  SHOW SCHEMAS FROM lakehouse;\n\n  SHOW TABLES FROM lakehouse.nyc_tripdata;\n\n  DESCRIBE lakehouse.nyc_tripdata.yellow;\n  DESCRIBE lakehouse.nyc_tripdata.green;\n  DESCRIBE lakehouse.nyc_tripdata.fhv;\n\n  SELECT *\n  FROM lakehouse.nyc_tripdata.yellow\n  LIMIT 10;\nSQL\n"` |  |
-| extraEnvRaw | list | `[]` | Extra environment variables in RAW format that will be passed into pods |
-| fullnameOverride | string | `""` |  |
-| image.pullPolicy | string | `"Always"` |  |
-| image.repository | string | `"quay.io/okdp/okdp-examples"` |  |
-| image.tag | string | `"latest"` |  |
-| imagePullSecrets | list | `[]` |  |
-| job.annotations."helm.sh/hook" | string | `"post-install,post-upgrade"` |  |
-| job.annotations."helm.sh/hook-delete-policy" | string | `"before-hook-creation"` |  |
-| job.backoffLimit | int | `2` |  |
-| job.restartPolicy | string | `"Never"` |  |
-| nameOverride | string | `""` |  |
-| nodeSelector | object | `{}` |  |
-| podAnnotations | object | `{}` |  |
-| podLabels | object | `{}` |  |
-| podSecurityContext | object | `{}` |  |
-| resources | object | `{}` |  |
-| securityContext | object | `{}` |  |
-| serviceAccount.annotations | object | `{}` |  |
-| serviceAccount.automount | bool | `true` |  |
-| serviceAccount.create | bool | `true` |  |
-| serviceAccount.name | string | `""` |  |
-| tolerations | list | `[]` |  |
-| volumeMounts | list | `[]` |  |
-| volumes | list | `[]` |  |
+| affinity | object | `{}` | Affinity rules for scheduling the Job pod. |
+| commands | object | `{}` | Ordered command groups executed by the examples Job. The first-level key is the phase/group name, and the second-level key is the command step name. Each value is a shell script snippet. |
+| extraEnvRaw | list | `[]` | Extra environment variables in raw Kubernetes env format injected into the Job container. |
+| fullnameOverride | string | `""` | Override the fully qualified release name. |
+| image | object | `{"pullPolicy":"Always","repository":"quay.io/okdp/okdp-examples","tag":"latest"}` | Container image configuration for the examples Job. |
+| image.pullPolicy | string | `"Always"` | Kubernetes image pull policy. |
+| image.repository | string | `"quay.io/okdp/okdp-examples"` | OCI image repository for the examples container. |
+| image.tag | string | `"latest"` | Image tag to use. Defaults are not inferred here; this value is explicit. |
+| imagePullSecrets | list | `[]` | Image pull secrets for private registries. |
+| job | object | `{"annotations":{"helm.sh/hook":"post-install,post-upgrade","helm.sh/hook-delete-policy":"before-hook-creation"},"backoffLimit":2,"restartPolicy":"Never"}` | Kubernetes Job configuration. |
+| job.annotations | object | `{"helm.sh/hook":"post-install,post-upgrade","helm.sh/hook-delete-policy":"before-hook-creation"}` | Annotations applied to the Job metadata, typically used for Helm hooks. |
+| job.backoffLimit | int | `2` | Number of retries before the Job is considered failed. |
+| job.restartPolicy | string | `"Never"` | Pod restart policy for the Job. |
+| nameOverride | string | `""` | Override the chart name. |
+| nodeSelector | object | `{}` | Node selector constraints for scheduling the Job pod. |
+| podAnnotations | object | `{}` | Additional annotations added to the pod template. |
+| podLabels | object | `{}` | Additional labels added to the pod template. |
+| podSecurityContext | object | `{}` | Pod-level security context. |
+| resources | object | `{}` | Resource requests and limits for the Job container. |
+| securityContext | object | `{}` | Container-level security context. |
+| serviceAccount | object | `{"annotations":{},"automount":true,"create":true,"name":""}` | ServiceAccount configuration for the Job pod. |
+| serviceAccount.annotations | object | `{}` | Additional annotations added to the ServiceAccount. |
+| serviceAccount.automount | bool | `true` | Automatically mount the ServiceAccount token into the pod. |
+| serviceAccount.create | bool | `true` | Specifies whether a ServiceAccount should be created. |
+| serviceAccount.name | string | `""` | Name of the ServiceAccount to use. If empty and create=true, a name is generated. |
+| tolerations | list | `[]` | Tolerations for scheduling the Job pod onto tainted nodes. |
+| volumeMounts | list | `[]` | Additional volume mounts added to the Job container. |
+| volumes | list | `[]` | Additional volumes added to the Job pod. |
 
 ----------------------------------------------
 Autogenerated from chart metadata using [helm-docs v1.13.1](https://github.com/norwoodj/helm-docs/releases/v1.13.1)
diff --git a/helm/okdp-examples/templates/_helpers.tpl b/helm/okdp-examples/templates/_helpers.tpl
index 23f9f2e..d735331 100644
--- a/helm/okdp-examples/templates/_helpers.tpl
+++ b/helm/okdp-examples/templates/_helpers.tpl
@@ -1,3 +1,21 @@
+{{/*
+
+ Copyright 2026 The OKDP Authors.
+
+ Licensed under the Apache License, Version 2.0 (the "License");
+ you may not use this file except in compliance with the License.
+ You may obtain a copy of the License at
+
+     http://www.apache.org/licenses/LICENSE-2.0
+
+ Unless required by applicable law or agreed to in writing, software
+ distributed under the License is distributed on an "AS IS" BASIS,
+ WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ See the License for the specific language governing permissions and
+ limitations under the License.
+
+*/}}
+
 {{/*
 Expand the name of the chart.
 */}}
diff --git a/helm/okdp-examples/templates/configmap.yaml b/helm/okdp-examples/templates/configmap.yaml
index 6cbddc9..4566eee 100644
--- a/helm/okdp-examples/templates/configmap.yaml
+++ b/helm/okdp-examples/templates/configmap.yaml
@@ -1,18 +1,20 @@
-#
-# Copyright 2026 The OKDP Authors.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#      http://www.apache.org/licenses/LICENSE-2.0
-#
-#  Unless required by applicable law or agreed to in writing, software
-#  distributed under the License is distributed on an "AS IS" BASIS,
-#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-#  See the License for the specific language governing permissions and
-#  limitations under the License.
-#
+{{/*
+  
+  Copyright 2026 The OKDP Authors.
+  
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+  
+  http://www.apache.org/licenses/LICENSE-2.0
+  
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+
+*/}}
 
 {{- $root := . }}
 {{- $groupNames := sortAlpha (keys $root.Values.commands) }}
diff --git a/helm/okdp-examples/templates/job.yaml b/helm/okdp-examples/templates/job.yaml
index 1df9f2c..34a736f 100644
--- a/helm/okdp-examples/templates/job.yaml
+++ b/helm/okdp-examples/templates/job.yaml
@@ -1,21 +1,23 @@
-#
-# Copyright 2026 The OKDP Authors.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#      http://www.apache.org/licenses/LICENSE-2.0
-#
-#  Unless required by applicable law or agreed to in writing, software
-#  distributed under the License is distributed on an "AS IS" BASIS,
-#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-#  See the License for the specific language governing permissions and
-#  limitations under the License.
-#
+{{/*
+  
+  Copyright 2026 The OKDP Authors.
+  
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+  
+  http://www.apache.org/licenses/LICENSE-2.0
+  
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+
+*/}}
 
 {{- $root := . }}
-  {{- $groupNames := sortAlpha (keys $root.Values.commands) }}
+{{- $groupNames := sortAlpha (keys $root.Values.commands) }}
 apiVersion: batch/v1
 kind: Job
 metadata:
diff --git a/helm/okdp-examples/templates/serviceaccount.yaml b/helm/okdp-examples/templates/serviceaccount.yaml
index 655aa9d..8a3732c 100644
--- a/helm/okdp-examples/templates/serviceaccount.yaml
+++ b/helm/okdp-examples/templates/serviceaccount.yaml
@@ -1,18 +1,20 @@
-#
-# Copyright 2026 The OKDP Authors.
-#
-# Licensed under the Apache License, Version 2.0 (the "License");
-# you may not use this file except in compliance with the License.
-# You may obtain a copy of the License at
-#
-#      http://www.apache.org/licenses/LICENSE-2.0
-#
-#  Unless required by applicable law or agreed to in writing, software
-#  distributed under the License is distributed on an "AS IS" BASIS,
-#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-#  See the License for the specific language governing permissions and
-#  limitations under the License.
-#
+{{/*
+  
+  Copyright 2026 The OKDP Authors.
+  
+  Licensed under the Apache License, Version 2.0 (the "License");
+  you may not use this file except in compliance with the License.
+  You may obtain a copy of the License at
+  
+  http://www.apache.org/licenses/LICENSE-2.0
+  
+  Unless required by applicable law or agreed to in writing, software
+  distributed under the License is distributed on an "AS IS" BASIS,
+  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  See the License for the specific language governing permissions and
+  limitations under the License.
+
+*/}}
 
 {{- if .Values.serviceAccount.create -}}
 apiVersion: v1
diff --git a/helm/okdp-examples/values.yaml b/helm/okdp-examples/values.yaml
index 91ecab0..9550ce6 100644
--- a/helm/okdp-examples/values.yaml
+++ b/helm/okdp-examples/values.yaml
@@ -14,28 +14,36 @@
 #  limitations under the License.
 #
 
-# Default values for okdp-examples.
-# This is a YAML-formatted file.
-# Declare variables to be passed into your templates.
-
+# -- Container image configuration for the examples Job.
 image:
+  # -- OCI image repository for the examples container.
   repository: quay.io/okdp/okdp-examples
+  # -- Kubernetes image pull policy.
   pullPolicy: Always
-  # Overrides the image tag whose default is the chart appVersion.
+  # -- Image tag to use. Defaults are not inferred here; this value is explicit.
   tag: "latest"
 
+# -- Image pull secrets for private registries.
 imagePullSecrets: []
+
+# -- Override the chart name.
 nameOverride: ""
+
+# -- Override the fully qualified release name.
 fullnameOverride: ""
 
+# -- Kubernetes Job configuration.
 job:
+  # -- Pod restart policy for the Job.
   restartPolicy: Never
+  # -- Number of retries before the Job is considered failed.
   backoffLimit: 2
+  # -- Annotations applied to the Job metadata, typically used for Helm hooks.
   annotations:
     "helm.sh/hook": post-install,post-upgrade
     "helm.sh/hook-delete-policy": "before-hook-creation"
 
-# -- Extra environment variables in RAW format that will be passed into pods
+# -- Extra environment variables in raw Kubernetes env format injected into the Job container.
 extraEnvRaw: []
 #  - name: MC_INSECURE
 #    value: "1"
@@ -64,206 +72,213 @@ extraEnvRaw: []
 #  - name: SPARK_EVENT_LOG_DIRECTORY
 #    value: s3a://spark-events/event-logs/
 
-commands:
-  01-prepare_env:
-    01-create-spark-event-log-dir: |
-      echo "👉 Connect into S3"
-      mc alias set myminio $S3_ENDPOINT "$S3_ACCESS_KEY" "$S3_SECRET_KEY"
-      echo "👉 MinIO alias configured successfully."
-      echo "👉 Normalize the log directory $SPARK_EVENT_LOG_DIRECTORY"
-      no_scheme="${SPARK_EVENT_LOG_DIRECTORY#s3a://}"
-      no_scheme="${no_scheme%/}"
-      bucket="${no_scheme%%/*}"
-      prefix="${no_scheme#${bucket}}"
-      prefix="${prefix#/}"
-      echo "👉 Bucket: $bucket, Prefix: $prefix"
-      echo "👉 Create the bucket $bucket if not exist"
-      mc mb myminio/$bucket || true
-      echo "👉 upload a zero-byte object to create the prefix: ${bucket}/${prefix}/.keep"
-      mc pipe "myminio/${bucket}/${prefix}/.keep" < /dev/null
-      echo "✅ Spark events log directory $SPARK_EVENT_LOG_DIRECTORY successfully created.";
-  02-nyc_trip:
-    # https://www.nyc.gov/site/tlc/about/tlc-trip-record-data.page
-    01-download-nyc-tripdata: |
-      mkdir -p /data/tripdata
-      cd /data/tripdata;
-      for dataset in yellow green fhv; do
-        for month in 01 02 03; do
-          file="${dataset}_tripdata_2025-${month}.parquet";
-          url="$DATA_URL/$file";
-          echo "→ $url";
-          if curl -fsSLO "$url"; then
-            echo "✅ Downloaded: $file";
-          else
-            echo "⚠️ Missing: $file";
-          fi;
-        done;
-      done;
-      ls -lh /data/tripdata
-      echo "✅ All downloads complete.";
-
-    02-upload-nyc-tripdata-into-s3: |
-      echo "👉 Connect into S3"
-      mc alias set myminio $S3_ENDPOINT "$S3_ACCESS_KEY" "$S3_SECRET_KEY"
-      echo "👉 MinIO alias configured successfully."
-      ### echo "👉 Clean the examples folder if it exists"
-      ### mc rm --recursive --force myminio/$BUCKET/examples
-      echo "👉 Create the bucket if not exist"
-      mc mb myminio/$BUCKET || true
-      echo "👉 Upload sample files into the correct folders"
-      
-      for category in yellow green fhv; do
-        echo "🚀 Processing category: $category"
-        for file in /data/tripdata/${category}_*.parquet; do
-          [ -e "$file" ] || continue  # skip if no files match
-          month=$(basename "$file" | sed -E 's/.*_([0-9]{4}-[0-9]{2})\.parquet/\1/')
-          echo "📦 Uploading $file → ${BUCKET_PREFIX}/$category/month=$month/"
-          mc cp "$file" "myminio/$BUCKET/${BUCKET_PREFIX}/$category/month=$month/"
-        done
-      done
-      
-      echo "👉 Verify bucket structure"
-      mc tree myminio/$BUCKET
-      mc ls --recursive myminio/$BUCKET
-
-    03-nyc-tripdata-trino-external-tables.sql: |
-      trino --server ${TRINO_SERVER_URL} --insecure <<SQL
-        CREATE SCHEMA IF NOT EXISTS lakehouse.nyc_tripdata;
-      
-        CREATE TABLE IF NOT EXISTS lakehouse.nyc_tripdata.yellow (
-          vendorid INT,
-          tpep_pickup_datetime TIMESTAMP,
-          tpep_dropoff_datetime TIMESTAMP,
-          passenger_count INT,
-          trip_distance DOUBLE,
-          ratecodeid INT,
-          store_and_fwd_flag VARCHAR,
-          pulocationid INT,
-          dolocationid INT,
-          payment_type INT,
-          fare_amount DOUBLE,
-          extra DOUBLE,
-          mta_tax DOUBLE,
-          tip_amount DOUBLE,
-          tolls_amount DOUBLE,
-          improvement_surcharge DOUBLE,
-          total_amount DOUBLE,
-          congestion_surcharge DOUBLE,
-          airport_fee DOUBLE,
-          cbd_congestion_fee DOUBLE,
-          month VARCHAR
-        )
-        WITH (
-          external_location = 's3a://${BUCKET}/${BUCKET_PREFIX}/yellow/',
-          format = 'PARQUET',
-          partitioned_by = ARRAY['month']
-        );
-      
-        CREATE TABLE IF NOT EXISTS lakehouse.nyc_tripdata.green (
-          vendorid INT,
-          lpep_pickup_datetime TIMESTAMP,
-          lpep_dropoff_datetime TIMESTAMP,
-          store_and_fwd_flag VARCHAR,
-          ratecodeid INT,
-          pulocationid INT,
-          dolocationid INT,
-          passenger_count INT,
-          trip_distance DOUBLE,
-          fare_amount DOUBLE,
-          extra DOUBLE,
-          mta_tax DOUBLE,
-          tip_amount DOUBLE,
-          tolls_amount DOUBLE,
-          improvement_surcharge DOUBLE,
-          total_amount DOUBLE,
-          payment_type INT,
-          trip_type INT,
-          congestion_surcharge DOUBLE,
-          cbd_congestion_fee DOUBLE,
-          month VARCHAR
-        )
-        WITH (
-          external_location = 's3a://${BUCKET}/${BUCKET_PREFIX}/green/',
-          format = 'PARQUET',
-          partitioned_by = ARRAY['month']
-        );
-      
-        CREATE TABLE IF NOT EXISTS lakehouse.nyc_tripdata.fhv (
-          dispatching_base_num VARCHAR,
-          pickup_datetime TIMESTAMP,
-          dropoff_datetime TIMESTAMP,
-          pulocationid INT,
-          dolocationid INT,
-          sr_flag INT,
-          affiliated_base_number VARCHAR,
-          month VARCHAR
-        )
-        WITH (
-          external_location = 's3a://${BUCKET}/${BUCKET_PREFIX}/fhv/',
-          format = 'PARQUET',
-          partitioned_by = ARRAY['month']
-        );
-      SQL
-
-    04-nyc-tripdata-trino-synchronize-partitions: |
-      trino --server ${TRINO_SERVER_URL} --insecure <<SQL
-        CALL lakehouse.system.sync_partition_metadata(
-          schema_name => 'nyc_tripdata',
-          table_name => 'yellow',
-          mode => 'ADD'
-        );
-        CALL lakehouse.system.sync_partition_metadata(
-          schema_name => 'nyc_tripdata',
-          table_name => 'green',
-          mode => 'ADD'
-        );
-        CALL lakehouse.system.sync_partition_metadata(
-          schema_name => 'nyc_tripdata',
-          table_name => 'fhv',
-          mode => 'ADD'
-        );
-      SQL
-
-    05-nyc-tripdata-trino-validate: |
-      trino --server ${TRINO_SERVER_URL} --insecure <<SQL
-        SHOW SCHEMAS FROM lakehouse;
-      
-        SHOW TABLES FROM lakehouse.nyc_tripdata;
-      
-        DESCRIBE lakehouse.nyc_tripdata.yellow;
-        DESCRIBE lakehouse.nyc_tripdata.green;
-        DESCRIBE lakehouse.nyc_tripdata.fhv;
-      
-        SELECT *
-        FROM lakehouse.nyc_tripdata.yellow
-        LIMIT 10;
-      SQL
+# -- Ordered command groups executed by the examples Job. The first-level key is the phase/group name, and the second-level key is the command step name. Each value is a shell script snippet.
+commands: {}
+#  01-prepare_env:
+#    01-create-spark-event-log-dir: |
+#      echo "👉 Connect into S3"
+#      mc alias set myminio $S3_ENDPOINT "$S3_ACCESS_KEY" "$S3_SECRET_KEY"
+#      echo "👉 MinIO alias configured successfully."
+#      echo "👉 Normalize the log directory $SPARK_EVENT_LOG_DIRECTORY"
+#      no_scheme="${SPARK_EVENT_LOG_DIRECTORY#s3a://}"
+#      no_scheme="${no_scheme%/}"
+#      bucket="${no_scheme%%/*}"
+#      prefix="${no_scheme#${bucket}}"
+#      prefix="${prefix#/}"
+#      echo "👉 Bucket: $bucket, Prefix: $prefix"
+#      echo "👉 Create the bucket $bucket if not exist"
+#      mc mb myminio/$bucket || true
+#      echo "👉 upload a zero-byte object to create the prefix: ${bucket}/${prefix}/.keep"
+#      mc pipe "myminio/${bucket}/${prefix}/.keep" < /dev/null
+#      echo "✅ Spark events log directory $SPARK_EVENT_LOG_DIRECTORY successfully created.";
+#  02-nyc_trip:
+#    # https://www.nyc.gov/site/tlc/about/tlc-trip-record-data.page
+#    01-download-nyc-tripdata: |
+#      mkdir -p /data/tripdata
+#      cd /data/tripdata;
+#      for dataset in yellow green fhv; do
+#        for month in 01 02 03; do
+#          file="${dataset}_tripdata_2025-${month}.parquet";
+#          url="$DATA_URL/$file";
+#          echo "→ $url";
+#          if curl -fsSLO "$url"; then
+#            echo "✅ Downloaded: $file";
+#          else
+#            echo "⚠️ Missing: $file";
+#          fi;
+#        done;
+#      done;
+#      ls -lh /data/tripdata
+#      echo "✅ All downloads complete.";
+#
+#    02-upload-nyc-tripdata-into-s3: |
+#      echo "👉 Connect into S3"
+#      mc alias set myminio $S3_ENDPOINT "$S3_ACCESS_KEY" "$S3_SECRET_KEY"
+#      echo "👉 MinIO alias configured successfully."
+#      ### echo "👉 Clean the examples folder if it exists"
+#      ### mc rm --recursive --force myminio/$BUCKET/examples
+#      echo "👉 Create the bucket if not exist"
+#      mc mb myminio/$BUCKET || true
+#      echo "👉 Upload sample files into the correct folders"
+#
+#      for category in yellow green fhv; do
+#        echo "🚀 Processing category: $category"
+#        for file in /data/tripdata/${category}_*.parquet; do
+#          [ -e "$file" ] || continue  # skip if no files match
+#          month=$(basename "$file" | sed -E 's/.*_([0-9]{4}-[0-9]{2})\.parquet/\1/')
+#          echo "📦 Uploading $file → ${BUCKET_PREFIX}/$category/month=$month/"
+#          mc cp "$file" "myminio/$BUCKET/${BUCKET_PREFIX}/$category/month=$month/"
+#        done
+#      done
+#
+#      echo "👉 Verify bucket structure"
+#      mc tree myminio/$BUCKET
+#      mc ls --recursive myminio/$BUCKET
+#
+#    03-nyc-tripdata-trino-external-tables.sql: |
+#      trino --server ${TRINO_SERVER_URL} --insecure <<SQL
+#        CREATE SCHEMA IF NOT EXISTS lakehouse.nyc_tripdata;
+#
+#        CREATE TABLE IF NOT EXISTS lakehouse.nyc_tripdata.yellow (
+#          vendorid INT,
+#          tpep_pickup_datetime TIMESTAMP,
+#          tpep_dropoff_datetime TIMESTAMP,
+#          passenger_count INT,
+#          trip_distance DOUBLE,
+#          ratecodeid INT,
+#          store_and_fwd_flag VARCHAR,
+#          pulocationid INT,
+#          dolocationid INT,
+#          payment_type INT,
+#          fare_amount DOUBLE,
+#          extra DOUBLE,
+#          mta_tax DOUBLE,
+#          tip_amount DOUBLE,
+#          tolls_amount DOUBLE,
+#          improvement_surcharge DOUBLE,
+#          total_amount DOUBLE,
+#          congestion_surcharge DOUBLE,
+#          airport_fee DOUBLE,
+#          cbd_congestion_fee DOUBLE,
+#          month VARCHAR
+#        )
+#        WITH (
+#          external_location = 's3a://${BUCKET}/${BUCKET_PREFIX}/yellow/',
+#          format = 'PARQUET',
+#          partitioned_by = ARRAY['month']
+#        );
+#
+#        CREATE TABLE IF NOT EXISTS lakehouse.nyc_tripdata.green (
+#          vendorid INT,
+#          lpep_pickup_datetime TIMESTAMP,
+#          lpep_dropoff_datetime TIMESTAMP,
+#          store_and_fwd_flag VARCHAR,
+#          ratecodeid INT,
+#          pulocationid INT,
+#          dolocationid INT,
+#          passenger_count INT,
+#          trip_distance DOUBLE,
+#          fare_amount DOUBLE,
+#          extra DOUBLE,
+#          mta_tax DOUBLE,
+#          tip_amount DOUBLE,
+#          tolls_amount DOUBLE,
+#          improvement_surcharge DOUBLE,
+#          total_amount DOUBLE,
+#          payment_type INT,
+#          trip_type INT,
+#          congestion_surcharge DOUBLE,
+#          cbd_congestion_fee DOUBLE,
+#          month VARCHAR
+#        )
+#        WITH (
+#          external_location = 's3a://${BUCKET}/${BUCKET_PREFIX}/green/',
+#          format = 'PARQUET',
+#          partitioned_by = ARRAY['month']
+#        );
+#
+#        CREATE TABLE IF NOT EXISTS lakehouse.nyc_tripdata.fhv (
+#          dispatching_base_num VARCHAR,
+#          pickup_datetime TIMESTAMP,
+#          dropoff_datetime TIMESTAMP,
+#          pulocationid INT,
+#          dolocationid INT,
+#          sr_flag INT,
+#          affiliated_base_number VARCHAR,
+#          month VARCHAR
+#        )
+#        WITH (
+#          external_location = 's3a://${BUCKET}/${BUCKET_PREFIX}/fhv/',
+#          format = 'PARQUET',
+#          partitioned_by = ARRAY['month']
+#        );
+#      SQL
+#
+#    04-nyc-tripdata-trino-synchronize-partitions: |
+#      trino --server ${TRINO_SERVER_URL} --insecure <<SQL
+#        CALL lakehouse.system.sync_partition_metadata(
+#          schema_name => 'nyc_tripdata',
+#          table_name => 'yellow',
+#          mode => 'ADD'
+#        );
+#        CALL lakehouse.system.sync_partition_metadata(
+#          schema_name => 'nyc_tripdata',
+#          table_name => 'green',
+#          mode => 'ADD'
+#        );
+#        CALL lakehouse.system.sync_partition_metadata(
+#          schema_name => 'nyc_tripdata',
+#          table_name => 'fhv',
+#          mode => 'ADD'
+#        );
+#      SQL
+#
+#    05-nyc-tripdata-trino-validate: |
+#      trino --server ${TRINO_SERVER_URL} --insecure <<SQL
+#        SHOW SCHEMAS FROM lakehouse;
+#
+#        SHOW TABLES FROM lakehouse.nyc_tripdata;
+#
+#        DESCRIBE lakehouse.nyc_tripdata.yellow;
+#        DESCRIBE lakehouse.nyc_tripdata.green;
+#        DESCRIBE lakehouse.nyc_tripdata.fhv;
+#
+#        SELECT *
+#        FROM lakehouse.nyc_tripdata.yellow
+#        LIMIT 10;
+#      SQL
 
+# -- ServiceAccount configuration for the Job pod.
 serviceAccount:
-  # Specifies whether a service account should be created
+  # -- Specifies whether a ServiceAccount should be created.
   create: true
-  # Automatically mount a ServiceAccount's API credentials?
+  # -- Automatically mount the ServiceAccount token into the pod.
   automount: true
-  # Annotations to add to the service account
+  # -- Additional annotations added to the ServiceAccount.
   annotations: {}
-  # The name of the service account to use.
-  # If not set and create is true, a name is generated using the fullname template
+  # -- Name of the ServiceAccount to use. If empty and create=true, a name is generated.
   name: ""
 
+# -- Additional annotations added to the pod template.
 podAnnotations: {}
+
+# -- Additional labels added to the pod template.
 podLabels: {}
 
+# -- Pod-level security context.
 podSecurityContext: {}
-  # fsGroup: 2000
+# fsGroup: 2000
 
+# -- Container-level security context.
 securityContext: {}
   # capabilities:
   #   drop:
   #   - ALL
   # readOnlyRootFilesystem: true
-  # runAsNonRoot: true
-  # runAsUser: 1000
+# runAsNonRoot: true
+# runAsUser: 1000
 
+# -- Resource requests and limits for the Job container.
 resources: {}
   # We usually recommend not to specify default resources and to leave this as a conscious
   # choice for the user. This also increases chances charts run on environments with little
@@ -273,24 +288,27 @@ resources: {}
   #   cpu: 100m
   #   memory: 128Mi
   # requests:
-  #   cpu: 100m
-  #   memory: 128Mi
+#   cpu: 100m
+#   memory: 128Mi
 
-# Additional volumes on the output Deployment definition.
+# -- Additional volumes added to the Job pod.
 volumes: []
 # - name: foo
 #   secret:
 #     secretName: mysecret
 #     optional: false
 
-# Additional volumeMounts on the output Deployment definition.
+# -- Additional volume mounts added to the Job container.
 volumeMounts: []
 # - name: foo
 #   mountPath: "/etc/foo"
 #   readOnly: true
 
+# -- Node selector constraints for scheduling the Job pod.
 nodeSelector: {}
 
+# -- Tolerations for scheduling the Job pod onto tainted nodes.
 tolerations: []
 
+# -- Affinity rules for scheduling the Job pod.
 affinity: {}