Add async call

README.md

@@ -157,6 +157,9 @@ response = client.remove_service("service_name") # returns an http response
 ``` python
 # make a synchronous execution 
 response = client.run_service("service_name", input="input", output="out.png", timeout=100) # returns an http response
+
+# make an asynchronous execution
+response = client.run_service("service_name", input="input", async_call=True) # returns an http response
 ```
 
 #### Logs methods

oscar_python/default_client.py

@@ -2,37 +2,38 @@
 import oscar_python._utils as utils
 
 _RUN_PATH = "/run"
+_JOB_PATH = "/job"
 _POST = "post"
 
 
 class DefaultClient(metaclass=abc.ABCMeta):
 
     _AUTH_TYPE = ''
 
-    """ Run a synchronous execution.
+    """ Run an execution.
+    If async is set to True the execution is run asynchronously.
     If an output is provided the result is decoded onto the file.
     In both cases the function returns the HTTP response."""
     def run_service(self, name, **kwargs):
-        if "token" in kwargs.keys() and kwargs["token"]:
+        if kwargs.get("token"):
             token = kwargs["token"]
         else:
             token = self._get_token(name)
 
-        if "input" in kwargs.keys() and kwargs["input"]:
-            exec_input = kwargs["input"]
+        send_data = None
+        if kwargs.get("input"):
+            send_data = kwargs["input"]
+            if not isinstance(send_data, dict):
+                send_data = utils.encode_input(send_data)
 
-            if type(exec_input) is dict:
-                send_data = exec_input
-            else:
-                send_data = utils.encode_input(exec_input)
+        path = _RUN_PATH + "/"+name
+        if kwargs.get("async_call"):
+            path = _JOB_PATH + "/" + name
 
-            if "timeout" in kwargs.keys() and kwargs["timeout"]:
-                response = utils.make_request(self, _RUN_PATH+"/"+name, _POST, data=send_data, token=token, timeout=kwargs["timeout"])
-            else:
-                response = utils.make_request(self, _RUN_PATH+"/"+name, _POST, data=send_data, token=token)
+        response = utils.make_request(self, path, _POST, data=send_data,
+                                      token=token, timeout=kwargs.get("timeout"))
 
-            if "output" in kwargs.keys() and kwargs["output"]:
-                utils.decode_output(response.text, kwargs["output"])
-            return response
+        if kwargs.get("output"):
+            utils.decode_output(response.text, kwargs["output"])
 
-        return utils.make_request(self, _RUN_PATH+"/"+name, _POST, token=token)
+        return response

tests/test_default_client.py

@@ -1,6 +1,6 @@
 import pytest
 from unittest.mock import patch, MagicMock
-from oscar_python.default_client import DefaultClient, _RUN_PATH, _POST
+from oscar_python.default_client import DefaultClient, _RUN_PATH, _POST, _JOB_PATH
 
 
 class TestDefaultClient(DefaultClient):
@@ -41,7 +41,7 @@ def test_run_service_with_input_no_token(mock_encode_input, mock_make_request, c
     response = client.run_service("test_service", input="test_input")
 
     mock_encode_input.assert_called_once_with("test_input")
-    mock_make_request.assert_called_once_with(client, _RUN_PATH+"/test_service", _POST, data="encoded_input", token="test_token")
+    mock_make_request.assert_called_once_with(client, _RUN_PATH+"/test_service", _POST, data="encoded_input", token="test_token", timeout=None)
     assert response == mock_response
 
 
@@ -51,7 +51,11 @@ def test_run_service_no_input(mock_make_request, client):
     mock_response.text = "response_text"
     mock_make_request.return_value = mock_response
 
-    response = client.run_service("test_service")
+    response = client.run_service("test_service", input="data")
+    mock_make_request.assert_called_with(client, _RUN_PATH+"/test_service", _POST,
+                                         token="test_token", data=b'ZGF0YQ==', timeout=None)
 
-    mock_make_request.assert_called_once_with(client, _RUN_PATH+"/test_service", _POST, token="test_token")
+    response = client.run_service("test_service", input="data", async_call=True, timeout=30)
+    mock_make_request.assert_called_with(client, _JOB_PATH+"/test_service", _POST,
+                                         token="test_token", data=b'ZGF0YQ==', timeout=30)
     assert response == mock_response