PyPiRunner class

alice-ci/src/alice/cli.py

@@ -33,7 +33,6 @@ def parse_jobs(args):
                 print(f"[Alice][Step] {step}: {status}")
             else:
                 raise ConfigException(f"Step {step} not found in {args.input}")
-                exit(1)
     except ConfigException as e:
         print(f"Configuration error-> {e}")
         exit(1)

alice-ci/src/alice/runnerfactory.py

@@ -1,4 +1,5 @@
 from alice.runners.pythonrunner import PythonRunner
+from alice.runners.pypirunner import PyPiRunner
 from alice.exceptions import ConfigException
 
 
@@ -15,7 +16,8 @@ class Factory():
         # https://git.gyulai.cloud/gyulaid/alice/issues/4
         # module = __import__("module_file")
         # my_class = getattr(module, "class_name")
-        runners = {"python": PythonRunner}
+        runners = {"python": PythonRunner,
+                   "pypi": PyPiRunner}
 
         if (self.verbose):
             print(f"[Alice] Available runners: {'|'.join(runners.keys())}")

alice-ci/src/alice/runners/__init__.py

@@ -1,2 +1,3 @@
 # flake8: noqa F401
 from alice.runners.pythonrunner import PythonRunner
+from alice.runners.pypirunner import PyPiRunner

alice-ci/src/alice/runners/pypirunner.py

@@ -0,0 +1,29 @@
+import json
+import sys
+from urllib import request    
+from pkg_resources import parse_version   
+
+from alice.exceptions import NonZeroRetcode, RunnerError, ConfigException
+
+
+class PyPiRunner():
+    def __init__(self, params, user_defaults) -> None:
+        self.verbose = params["verbose"]
+        if self.verbose:
+            print("[PyPiRunner] Initializing")
+        self.workdir = user_defaults["workdir"]
+        # config only contains env and workdir
+        self.config = user_defaults
+        self.default_repo = "https://pypi.python.org/pypi"
+
+    def __versions(self, pkg_name):
+        # TODO: Error handling
+        url = f'{self.default_repo}/{pkg_name}/json'
+        releases = json.loads(request.urlopen(url).read())['releases']
+        return sorted(releases, key=parse_version, reverse=True) 
+
+    def update_config(self, config):
+        print(config)
+
+    def run(self, job_spec):
+        print(self.__versions("alice-ci"))

alice-ci/src/alice/runners/pythonrunner.py

@@ -42,6 +42,8 @@ class PythonRunner():
     # Also - dependency install by config is only allowed in this step
     def update_config(self, config):
         if "dependencies" in config:
+            # TODO: Use pip freeze to list installed packages, only install missing
+            # ...or just dump the dependencies in a single list, and let pip deal with it.
             for dependency in config["dependencies"]:
                 # TODO: Check what happens with fixed version
                 command = [self.vpython, "-m", "pip", "install", dependency, "--upgrade"]

ci-examples/full.yaml

@@ -28,6 +28,18 @@ jobs:
     commands:
       - "-c \"import os; print(os.environ)\""
   - name: lint
+    type: python
     workdir: alice-ci
     commands:
       - "-m flake8 --ignore E501"
+  - name: pkg
+    type: pypi
+    workdir: .
+    upload: false
+    repo:
+      uri: example.com
+      username: asdf
+      password:
+        from_env: PYPIPASS
+    packages:
+     - alice-ci