Account for when workflows dir doesn't exist yet.

Author: DailyDreaming

wes_client/util.py

@@ -111,7 +111,6 @@ def get_service_info(self):
         WES API versions supported, and information about general
         the service availability.
 
-        :param object http_client: bravado.requests_client.RequestsClient
         :param str auth: String to send in the auth header.
         :param proto: Schema where the server resides (http, https)
         :param host: Port where the post request will be sent and the wes server listens at (default 8080)
@@ -128,7 +127,6 @@ def list_runs(self):
         live updates as the user traverses the pages, the behavior
         should be decided (and documented) by each implementation.
 
-        :param object http_client: bravado.requests_client.RequestsClient
         :param str auth: String to send in the auth header.
         :param proto: Schema where the server resides (http, https)
         :param host: Port where the post request will be sent and the wes server listens at (default 8080)
@@ -145,7 +143,6 @@ def run(self, wf, jsonyaml, attachments):
         :param str workflow_file: A local/http/https path to a cwl/wdl/python workflow file.
         :param str jsonyaml: A local path to a json or yaml file.
         :param list attachments: A list of local paths to files that will be uploaded to the server.
-        :param object http_client: bravado.requests_client.RequestsClient
         :param str auth: String to send in the auth header.
         :param proto: Schema where the server resides (http, https)
         :param host: Port where the post request will be sent and the wes server listens at (default 8080)
@@ -163,7 +160,6 @@ def cancel(self, run_id):
         Cancel a running workflow.
 
         :param run_id: String (typically a uuid) identifying the run.
-        :param object http_client: bravado.requests_client.RequestsClient
         :param str auth: String to send in the auth header.
         :param proto: Schema where the server resides (http, https)
         :param host: Port where the post request will be sent and the wes server listens at (default 8080)
@@ -178,7 +174,6 @@ def get_run_log(self, run_id):
         Get detailed info about a running workflow.
 
         :param run_id: String (typically a uuid) identifying the run.
-        :param object http_client: bravado.requests_client.RequestsClient
         :param str auth: String to send in the auth header.
         :param proto: Schema where the server resides (http, https)
         :param host: Port where the post request will be sent and the wes server listens at (default 8080)
@@ -193,7 +188,6 @@ def get_run_status(self, run_id):
         Get quick status info about a running workflow.
 
         :param run_id: String (typically a uuid) identifying the run.
-        :param object http_client: bravado.requests_client.RequestsClient
         :param str auth: String to send in the auth header.
         :param proto: Schema where the server resides (http, https)
         :param host: Port where the post request will be sent and the wes server listens at (default 8080)

wes_service/cwl_runner.py

@@ -173,6 +173,8 @@ def GetServiceInfo(self):
 
     def ListRuns(self, page_size=None, page_token=None, state_search=None):
         # FIXME #15 results don't page
+        if not os.path.exists(os.path.join(os.getcwd(), "workflows")):
+            return {"workflows": [], "next_page_token": ""}
         wf = []
         for l in os.listdir(os.path.join(os.getcwd(), "workflows")):
             if os.path.isdir(os.path.join(os.getcwd(), "workflows", l)):

wes_service/toil_wes.py

@@ -298,6 +298,8 @@ def GetServiceInfo(self):
 
     def ListRuns(self, page_size=None, page_token=None, state_search=None):
         # FIXME #15 results don't page
+        if not os.path.exists(os.path.join(os.getcwd(), "workflows")):
+            return {"workflows": [], "next_page_token": ""}
         wf = []
         for l in os.listdir(os.path.join(os.getcwd(), "workflows")):
             if os.path.isdir(os.path.join(os.getcwd(), "workflows", l)):