feat: conditional node

* feat: conditional node

* feat: working argo conditional

* feat: conditional node refactored

* feat: conditional node refactored

* feat: argo execution of the conditional

* feat: argo execution of the conditional

Author: vijayvammi

Dockerfile

@@ -1,23 +1,27 @@
 # Python 3.8 Image without Dependecies
-FROM ubuntu:24.04
+FROM python:3.10.16-slim
 
 LABEL maintainer="[email protected]"
 
-
+ENV http_proxy=http://azpse.astrazeneca.net:9480
+ENV https_proxy=http://azpse.astrazeneca.net:9480
 RUN apt-get update && apt-get install -y --no-install-recommends \
     git \
     ca-certificates \
     curl \
     && rm -rf /var/lib/apt/lists/*
 
+
 ADD https://astral.sh/uv/0.5.12/install.sh /uv-installer.sh
 RUN sh /uv-installer.sh && rm /uv-installer.sh
 ENV PATH="/root/.local/bin/:$PATH"
 
 COPY . /app
 WORKDIR /app
 
-RUN uv python install && \
-    uv sync --index https://artifactory.astrazeneca.net/api/pypi/pypi-virtual/simple/  --all-extras --frozen
+ENV http_proxy=
+ENV https_proxy=
+
+RUN uv sync --index https://artifactory.astrazeneca.net/api/pypi/pypi-virtual/simple/ --frozen
 
 ENV PATH="/app/.venv/bin:$PATH"

examples/01-tasks/python_task_as_pipeline.py

@@ -0,0 +1,29 @@
+"""
+You can execute this pipeline by:
+
+    python examples/01-tasks/python_tasks.py
+
+The stdout of "Hello World!" would be captured as execution
+log and stored in the catalog.
+"""
+
+from examples.common.functions import hello
+from runnable import PythonTask
+
+
+def main():
+    # Create a tasks which calls the function "hello"
+    # If this step executes successfully,
+    # the pipeline will terminate with success
+    pipeline = PythonTask(
+        name="hello",
+        function=hello,
+        terminate_with_success=True,
+    ).as_pipeline()
+
+    pipeline.execute()
+    return pipeline
+
+
+if __name__ == "__main__":
+    main()

examples/02-sequential/when.py

@@ -0,0 +1,54 @@
+from runnable import Conditional, Pipeline, PythonTask
+
+
+def when_heads_function():
+    print("when_heads_function called")
+
+
+def when_tails_function():
+    print("when_tails_function called")
+
+
+def toss_function():
+    import random
+
+    # Simulate a coin toss
+    toss = random.choice(["heads", "tails"])
+    print(f"Toss result: {toss}")
+    return toss
+
+
+def main():
+    when_heads_pipeline = PythonTask(
+        name="when_heads_task",
+        function=when_heads_function,
+    ).as_pipeline()
+
+    when_tails_pipeline = PythonTask(
+        name="when_tails_task",
+        function=when_tails_function,
+    ).as_pipeline()
+
+    conditional = Conditional(
+        name="conditional",
+        branches={
+            "heads": when_heads_pipeline,
+            "tails": when_tails_pipeline,
+        },
+        parameter="toss",
+    )
+
+    toss_task = PythonTask(
+        name="toss_task",
+        function=toss_function,
+        returns=["toss"],
+    )
+    pipeline = Pipeline(steps=[toss_task, conditional])
+
+    pipeline.execute()
+
+    return pipeline
+
+
+if __name__ == "__main__":
+    main()

examples/Dockerfile.39

@@ -14,16 +14,6 @@ pipeline-executor:
       env:
         - name: argo_env
           value: "argo"
-    overrides:
-      smaller:
-        image: $docker2
-        resources:
-            limits:
-              cpu: "1"
-              memory: 2Gi
-            requests:
-              cpu: "0.5"
-              memory: 500Mi
     argoWorkflow:
       metadata:
         generateName: "argo-" # (2)