From 05c69293ec4f946c38193af21483fdb6ec5a2c3b Mon Sep 17 00:00:00 2001
From: Marius Merschformann <marius.merschformann@gmail.com>
Date: Tue, 1 Oct 2024 22:42:52 +0200
Subject: [PATCH] Renaming publish to release for improved harmony

---
 .github/workflows/{publish.yml => release.yml} | 10 +++++-----
 nextpipe/flow.py                               | 10 ++++++++++
 2 files changed, 15 insertions(+), 5 deletions(-)
 rename .github/workflows/{publish.yml => release.yml} (94%)

diff --git a/.github/workflows/publish.yml b/.github/workflows/release.yml
similarity index 94%
rename from .github/workflows/publish.yml
rename to .github/workflows/release.yml
index aa3d32c..84dac10 100644
--- a/.github/workflows/publish.yml
+++ b/.github/workflows/release.yml
@@ -1,5 +1,5 @@
-name: publish
-run-name: Publish ${{ inputs.VERSION }} (pre-release - ${{ inputs.IS_PRE_RELEASE }}) by @${{ github.actor }} from ${{ github.ref_name }}
+name: release
+run-name: Release ${{ inputs.VERSION }} (pre-release - ${{ inputs.IS_PRE_RELEASE }}) by @${{ github.actor }} from ${{ github.ref_name }}
 
 on:
   workflow_dispatch:
@@ -82,7 +82,7 @@ jobs:
         run: python -m build
         working-directory: ./nextpipe
 
-  publish: # This job is used to publish the release to PyPI/TestPyPI
+  release: # This job is used to publish the release to PyPI/TestPyPI
     runs-on: ubuntu-latest
     needs: bump
     strategy:
@@ -132,8 +132,8 @@ jobs:
 
   notify:
     runs-on: ubuntu-latest
-    needs: publish
-    if: ${{ needs.publish.result == 'success' && inputs.IS_PRE_RELEASE == false }}
+    needs: release
+    if: ${{ needs.release.result == 'success' && inputs.IS_PRE_RELEASE == false }}
     steps:
       - name: notify slack
         run: |
diff --git a/nextpipe/flow.py b/nextpipe/flow.py
index a4bc308..b902150 100644
--- a/nextpipe/flow.py
+++ b/nextpipe/flow.py
@@ -6,12 +6,22 @@
 import time
 from typing import List, Optional, Union
 
+import nextmv
 from nextmv.cloud import Application, Client, StatusV2
 from pathos.multiprocessing import ProcessingPool as Pool
 
 from . import utils
 
 
+class FlowParameter(nextmv.Parameter):
+    """
+    Parameter that is used in a `FlowSpec`.
+    """
+
+    def __init__(self, name, type, default=None, description=None, required=False):
+        super().__init__(name, type, default, description, required)
+
+
 class DAGNode:
     def __init__(self, step_function, step_definition, docstring):
         self.step_function = step_function