From 4fdcbe620f9ea23e4ac73cbb277e13c291e41ae7 Mon Sep 17 00:00:00 2001 From: Natalia Serrano Date: Tue, 8 Oct 2024 11:03:17 +0200 Subject: [PATCH] refs #786 make ConsolaRemota() asynchronous --- src/opengnsys/modules/server/ogAdmClient/__init__.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/src/opengnsys/modules/server/ogAdmClient/__init__.py b/src/opengnsys/modules/server/ogAdmClient/__init__.py index abfaef8..27746a5 100644 --- a/src/opengnsys/modules/server/ogAdmClient/__init__.py +++ b/src/opengnsys/modules/server/ogAdmClient/__init__.py @@ -525,9 +525,7 @@ class ogAdmClientWorker (ogLiveWorker): logger.debug ('in process_Sondeo, path "{}" get_params "{}" post_params "{}" server "{}"'.format (path, get_params, post_params, server)) return {} ## ogAdmClient.c:920 - def process_ConsolaRemota (self, path, get_params, post_params, server): - logger.debug ('in process_ConsolaRemota, path "{}" get_params "{}" post_params "{}" server "{}"'.format (path, get_params, post_params, server)) - + def do_ConsolaRemota (self, post_params): for k in ['nfn', 'scp']: if k not in post_params: logger.error (f'required parameter ({k}) not in POST params') @@ -557,6 +555,10 @@ class ogAdmClientWorker (ogLiveWorker): return {} + def process_ConsolaRemota (self, path, get_params, post_params, server): + logger.debug ('in process_ConsolaRemota, path "{}" get_params "{}" post_params "{}" server "{}"'.format (path, get_params, post_params, server)) + return self._long_running_job ('ConsolaRemota', self.do_ConsolaRemota, args=(post_params,)) + def process_Arrancar (self, path, get_params, post_params, server): logger.debug ('in process_Arrancar, path "{}" get_params "{}" post_params "{}" server "{}"'.format (path, get_params, post_params, server))