feat: add run_async behaviour for device

Author: guptadev21

.gitignore

@@ -15,3 +15,5 @@ sdk_test/package_info.json
 config.json
 venv/
 htmlcov/
+ignore
+.vscode

rapyuta_io/clients/device.py

@@ -561,14 +561,16 @@ def execute_command(self, command, retry_limit=0):
          >>> device.execute_command(command)
 
         """
+        if command.bg:
+            command.cmd += ' &'
         command.validate()
         command.device_ids = [self.uuid]
         url = self._device_api_host + DEVICE_COMMAND_API_PATH
         response = self._execute_api(url, HttpMethod.POST, command.to_json(), retry_limit)
         if response.status_code == requests.codes.BAD_REQUEST:
             raise ParameterMissingException(get_error(response.text))
         execution_result = get_api_response_data(response)
-        if not command.bg:
+        if not command.bg and not command.run_async:
             return execution_result[self.uuid]
         jid = execution_result.get('jid')
         if not jid:

rapyuta_io/clients/model.py

@@ -61,14 +61,15 @@ class Command(ObjDict):
 
     """
 
-    def __init__(self, cmd, shell=None, env=None, bg=False, runas=None, pwd=None, cwd=None, timeout=300):
+    def __init__(self, cmd, shell=None, env=None, bg=False, run_async=False, runas=None, pwd=None, cwd=None, timeout=300):
         super(ObjDict, self).__init__()
         if env is None:
             env = dict()
         self.cmd = cmd
         self.shell = shell
         self.env = env
         self.bg = bg
+        self.run_async = run_async
         self.runas = runas
         self.cwd = pwd
         if cwd is not None:
@@ -83,6 +84,8 @@ def validate(self):
             raise InvalidCommandException("Invalid shell")
         if self.bg is not None and not isinstance(self.bg, bool):
             raise InvalidCommandException("Invalid background option")
+        if self.run_async is not None and not isinstance(self.run_async, bool):
+            raise InvalidCommandException("Invalid run asynchronous option")
         if self.runas is not None and not isinstance(self.runas, six.string_types):
             raise InvalidCommandException("Invalid runas option")
         if self.cwd is not None and not isinstance(self.cwd, six.string_types):