✨ 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

@@ -568,8 +568,9 @@ def execute_command(self, command, retry_limit=0):
         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:
-            return execution_result[self.uuid]
+        if not command.run_async:
+            return execution_result 
+        
         jid = execution_result.get('jid')
         if not jid:
             raise ValueError("Job ID not found in the response")

rapyuta_io/clients/device_manager.py

@@ -178,7 +178,7 @@ def execute_command(
 
         execution_result = get_api_response_data(response)
 
-        if not command.bg:
+        if not command.run_async:
             return execution_result
 
         jid = execution_result.get('jid')

rapyuta_io/clients/model.py

@@ -52,6 +52,7 @@ class Command(ObjDict):
     :ivar shell: Represents the shell where it is going to execute
     :ivar env: List of environment variables.
     :ivar bg: Boolean value specifying whether the execution runs on the background or not
+    :ivar run_async: Boolean value to specify to run command in async mode i.e., to run command and return its jid (not depending on completion of the command).
     :ivar runas: Run the command as a specific user
     :ivar cmd: Command to execute on the device
     :ivar pwd: Present working directory
@@ -61,14 +62,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 +85,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):