From 53550644299c130c3f07bbbf47057cf6ba4dd544 Mon Sep 17 00:00:00 2001
From: Andrey Tatarinov <a@tatarinov.co>
Date: Tue, 25 Jul 2023 02:40:16 +0400
Subject: [PATCH] datapipe 0.2.3

---
 charts/datapipe/CHANGELOG.md                             | 4 ++++
 charts/datapipe/Chart.yaml                               | 2 +-
 charts/datapipe/templates/loops-cronjob.yaml             | 3 +++
 charts/datapipe/tests/__snapshot__/simple_test.yaml.snap | 2 ++
 charts/datapipe/tests/simple-values.yaml                 | 2 ++
 charts/datapipe/values.yaml                              | 2 ++
 6 files changed, 14 insertions(+), 1 deletion(-)

diff --git a/charts/datapipe/CHANGELOG.md b/charts/datapipe/CHANGELOG.md
index 1f6b4ec..a815742 100644
--- a/charts/datapipe/CHANGELOG.md
+++ b/charts/datapipe/CHANGELOG.md
@@ -1,3 +1,7 @@
+# 0.2.3
+
+* Support custom pipeline module
+
 # 0.2.2
 
 * Include `fullName` into `CronJob` name
diff --git a/charts/datapipe/Chart.yaml b/charts/datapipe/Chart.yaml
index bb6d62f..cb429f4 100644
--- a/charts/datapipe/Chart.yaml
+++ b/charts/datapipe/Chart.yaml
@@ -15,7 +15,7 @@ type: application
 # This is the chart version. This version number should be incremented each time you make changes
 # to the chart and its templates, including the app version.
 # Versions are expected to follow Semantic Versioning (https://semver.org/)
-version: 0.2.2
+version: 0.2.3
 
 # This is the version number of the application being deployed. This version number should be
 # incremented each time you make changes to the application. Versions are not expected to
diff --git a/charts/datapipe/templates/loops-cronjob.yaml b/charts/datapipe/templates/loops-cronjob.yaml
index 6b2e765..567f6a3 100644
--- a/charts/datapipe/templates/loops-cronjob.yaml
+++ b/charts/datapipe/templates/loops-cronjob.yaml
@@ -24,6 +24,9 @@ spec:
             image: "{{ $.Values.image.repository }}:{{ $.Values.image.tag }}"
             command:
               - datapipe
+              {{- if $.Values.pipeline }}
+              - --pipeline={{ $.Values.pipeline }}
+              {{- end }}
               - step
               {{- if .stepArgs }}
               {{ .stepArgs | toYaml | nindent 14 }}
diff --git a/charts/datapipe/tests/__snapshot__/simple_test.yaml.snap b/charts/datapipe/tests/__snapshot__/simple_test.yaml.snap
index 884e2f2..0c20e2f 100644
--- a/charts/datapipe/tests/__snapshot__/simple_test.yaml.snap
+++ b/charts/datapipe/tests/__snapshot__/simple_test.yaml.snap
@@ -19,6 +19,7 @@ All manifests should match snapshot:
               containers:
                 - command:
                     - datapipe
+                    - --pipeline=custom_module.app
                     - step
                     - --labels=stage=loop-hourly
                     - run
@@ -52,6 +53,7 @@ All manifests should match snapshot:
               containers:
                 - command:
                     - datapipe
+                    - --pipeline=custom_module.app
                     - step
                     - --labels=stage=loop-daily
                     - run
diff --git a/charts/datapipe/tests/simple-values.yaml b/charts/datapipe/tests/simple-values.yaml
index d565c91..2a9a4ae 100644
--- a/charts/datapipe/tests/simple-values.yaml
+++ b/charts/datapipe/tests/simple-values.yaml
@@ -4,6 +4,8 @@ image:
   repository: test-datapipe
   tag: 1.1.1
 
+pipeline: custom_module.app
+
 env:
   - name: TEST_ENV
     value: "test"
diff --git a/charts/datapipe/values.yaml b/charts/datapipe/values.yaml
index 9e02c40..3b6d4c9 100644
--- a/charts/datapipe/values.yaml
+++ b/charts/datapipe/values.yaml
@@ -14,6 +14,8 @@ imagePullSecrets: []
 nameOverride: ""
 fullnameOverride: ""
 
+pipeline: ""
+
 loops: []
   # - name: name-of-the-regular-job
   #   schedule: "*/5 * * * *"