diff options
author | Sunil Shetye | 2025-05-23 15:27:02 +0530 |
---|---|---|
committer | Sunil Shetye | 2025-05-23 15:27:02 +0530 |
commit | 243cf969c5a906a307091a73e89c23d2fe524a22 (patch) | |
tree | 40d5750ff0d772f0cff01710160b61091a561766 | |
parent | 4f621331f7a56a83ab0cd501acd4a4cff811b68a (diff) | |
download | Common-Interface-Project-243cf969c5a906a307091a73e89c23d2fe524a22.tar.gz Common-Interface-Project-243cf969c5a906a307091a73e89c23d2fe524a22.tar.bz2 Common-Interface-Project-243cf969c5a906a307091a73e89c23d2fe524a22.zip |
replace current_process with status
-rw-r--r-- | blocks/simulationAPI/tasks.py | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/blocks/simulationAPI/tasks.py b/blocks/simulationAPI/tasks.py index 3e2b791b..8155b076 100644 --- a/blocks/simulationAPI/tasks.py +++ b/blocks/simulationAPI/tasks.py @@ -35,29 +35,28 @@ def process_task(self, task_id): logger.info("Processing %s %s %s %s", task_id, task.file.path, task.session.app_name, task.workspace_file) - update_task_status(task_id, 'STARTED', - meta={'current_process': 'Started Processing File'}) + state = 'STARTED' + status = 'Started Processing File' + update_task_status(task_id, state, meta={'status': status}) if task_type == 'SCRIPT': output = uploadscript(task.session, task) output = getscriptoutput(task.session, task) state = 'SUCCESS' - update_task_status(task_id, state, - meta=output) + update_task_status(task_id, state, meta=output) else: output = ExecXml(task, self.name, task.workspace_file) if output == "Streaming": state = 'STREAMING' - current_process = 'Processed Xml, Streaming Output' + status = 'Processed Xml, Streaming Output' elif output == "Success": state = 'SUCCESS' - current_process = 'Processed Xml, Loading Output' + status = 'Processed Xml, Loading Output' else: logger.error('%s', output) raise CannotRunParser(output) - update_task_status(task_id, state, - meta={'current_process': current_process}) + update_task_status(task_id, state, meta={'status': status}) return output |