Add HostClient-start-seq-py Sequence

Author: S4Adam

python/hostclient-start-seq-py/main.py

@@ -0,0 +1,34 @@
+import sys
+from scramjet.streams import Stream
+
+
+async def run(context, input, *args):
+    """
+    Sequence that starts any other Sequence, by giving its id as an argument.
+
+    Parameters:
+        input (any): dummy input, it takes no params
+        *args (tuple): Sequences ids that will be started
+
+    Returns:
+        stream: output stream with ids of started Instances
+    """
+    stream = Stream()
+    context.logger.info("Working...")
+    try:
+        # for each element in args tuple
+        for seq_id in args:
+            # get Sequence object
+            seq = await context.hub.get_sequence(seq_id)
+            context.logger.info(f"Sequence client called: {seq.id}")
+
+            inst = await seq.start()
+            context.logger.info(f"Sequence {seq_id} started: {inst.id}")
+            stream.write(inst.id)
+    
+    except Exception as e:
+        # if error occurs it will be logged under /instance/:id/stderr endpoint (CLI: si inst stderr <instID>)
+        print(e, file=sys.stderr)
+    finally:
+        stream.end()
+        return stream

python/hostclient-start-seq-py/package.json

@@ -0,0 +1,23 @@
+{
+    "name": "@scramjet/hostclient-start-seq-py",
+    "version": "0.1.0",
+    "main": "main.py",
+    "author": "Scramjet <open-source@scramjet.org>",
+    "description": "Sequence that starts any other Sequence, by providing its id as an argument.",
+    "license": "GPL-3.0",
+    "repository": {
+      "type": "git",
+      "url": "https://github.com/scramjetorg/transform-hub.git"
+    },
+    "engines": {
+      "python3": "3.9.0"
+    },
+    "scripts": {
+        "build:refapps": "yarn build:refapps:only",
+        "build:refapps:only": "mkdir -p dist/__pypackages__/ && cp *.py dist/ && pip3 install -t dist/__pypackages__/ -r requirements.txt",
+        "postbuild:refapps": "yarn prepack && yarn packseq",
+        "packseq": "PACKAGES_DIR=python node ../../scripts/packsequence.js",
+        "prepack": "PACKAGES_DIR=python node ../../scripts/publish.js",
+        "clean": "rm -rf ./dist"
+      }
+  }

python/hostclient-start-seq-py/requirements.txt

@@ -0,0 +1 @@
+scramjet-framework-py