OAProc: return statusInfo object on async (geopython#2105) (geopython#2106)

* OAProc: return statusInfo object on async (geopython#2105)

* fix ref

Author: tomkralidis

pygeoapi/api/processes.py

@@ -50,13 +50,13 @@
 
 from pygeoapi import l10n
 from pygeoapi.api import evaluate_limit
-from pygeoapi.util import (
-    json_serial, render_j2_template, JobStatus, RequestedProcessExecutionMode,
-    to_json, DATETIME_FORMAT)
 from pygeoapi.process.base import (
     JobNotFoundError, JobResultNotFoundError, ProcessorExecuteError
 )
 from pygeoapi.process.manager.base import get_manager, Subscriber
+from pygeoapi.util import (
+    json_serial, render_j2_template, JobStatus, RequestedProcessExecutionMode,
+    to_json, DATETIME_FORMAT)
 
 from . import (
     APIRequest, API, SYSTEM_LOCALE, F_JSON, FORMAT_TYPES, F_HTML, F_JSONLD,
@@ -520,6 +520,14 @@ def execute_process(api: API, request: APIRequest,
     else:
         response2 = response
 
+    if execution_mode == RequestedProcessExecutionMode.respond_async:
+        LOGGER.debug('Asynchronous mode detected, returning statusInfo')
+        response2 = {
+            'id': job_id,
+            'type': 'process',
+            'status': status.value
+        }
+
     return headers, http_status, response2
 
 

tests/api/test_processes.py

@@ -327,9 +327,13 @@ def test_execute_process(config, api_):
     rsp_headers, code, response = execute_process(api_, req, 'hello-world')
 
     assert 'Location' in rsp_headers
-    response = json.loads(response)
-    assert isinstance(response, dict)
     assert code == HTTPStatus.CREATED
+    assert isinstance(response, dict)
+    assert 'id' in response
+    assert 'type' in response
+    assert 'status' in response
+    assert response['type'] == 'process'
+    assert response['status'] == 'accepted'
 
     cleanup_jobs.add(tuple(['hello-world',
                             rsp_headers['Location'].split('/')[-1]]))