Renaming publish to release for improved harmony

.github/workflows/publish.yml → .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: |

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