Html output dummy instr

cdci_data_analysis/plugins/dummy_plugin/data_server_dispatcher.py

@@ -238,6 +238,43 @@
         return p_value, query_out
 
 
+class ReturnProgressHtmlDataServerQuery(DataServerQuery):
+    def __init__(self, config=None, instrument=None):
+        super().__init__()
+
+    def get_progress_run(self, **kwargs):
+
+        query_out = QueryOutput()
+
+        html_content = ReturnProgressHtmlProductQuery.get_progress_html_output()
+
+        query_out.set_status(
+            0,
+            message=f"current p value is {html_content}",
+            debug_message="no debug message really",
+            job_status="submitted",
+            comment="mock comment",
+            warning="mock warning")
+
+        return html_content, query_out
+
+    def run_query(self, *args, **kwargs):
+        logger.warn('fake run_query in %s with %s, %s', self, args, kwargs)
+        query_out = QueryOutput()
+
+        html_content = ReturnProgressProductQuery.get_progress_html_output()
+
+        query_out.set_status(
+            0,
+            message=f"current p value is {html_content}",
+            debug_message="no debug message really",
+            job_status="done",
+            comment="mock comment",
+            warning="mock warning")
+
+        return html_content, query_out
+
+
 class ReturnProgressProductQuery(ProductQuery):
 
     p_value_fn = "ReturnProgressProductQuery-current_p_value.out"
@@ -287,6 +324,49 @@
         p_value = res
         return [p_value]
 
+class ReturnProgressHtmlProductQuery(ReturnProgressProductQuery):
+
+    html_output_fn = "progress_html_output.html"
+    def __init__(self, name):
+        super().__init__(name)
+
+    @classmethod
+    def set_progress_html_output(cls, html_output_content):
+        with open(cls.html_output_fn, "w") as progress_html_f:
+            progress_html_f.write(str(html_output_content))
+
+    @classmethod
+    def get_progress_html_output(cls):
+        if os.path.exists(cls.html_output_fn):
+            with open(cls.html_output_fn) as html_output_f:
+                html_output = html_output_f.read()
+            return html_output
+        else:
+            return ""
+
+    def get_dummy_progress_run(self, instrument, config=None,**kwargs):
+        html_output = self.get_progress_html_output()
+        prod_list = QueryProductList(prod_list=[html_output])
+        return prod_list
+
+    def get_dummy_products(self, instrument, config=None, **kwargs):
+        html_output = self.get_progress_html_output()
+        prod_list = QueryProductList(prod_list=[html_output])
+        return prod_list
+
+    def process_product_method(self, instrument, prod_list, api=False, **kw):
+        query_out = QueryOutput()
+        query_out.prod_dictionary['progress_product_html_output'] = prod_list.prod_list[0]
+        return query_out
+
+    def get_data_server_query(self,instrument,config=None,**kwargs):
+        if instrument.data_server_query_class:
+            q = ReturnProgressHtmlDataServerQuery(instrument=instrument, config=config)
+        else:
+            q = DataServerQuery()
+        return q
+
+
 class EmptyProductQuery(ProductQuery):
 
     def __init__(self, name='unset-name', config=None, instrument=None):

cdci_data_analysis/plugins/dummy_plugin/empty_async_return_progress_instrument.py

@@ -5,7 +5,7 @@
 from cdci_data_analysis.analysis.instrument import Instrument
 from cdci_data_analysis.analysis.queries import SourceQuery, InstrumentQuery, Float
 
-from .data_server_dispatcher import ReturnProgressDataServerQuery, ReturnProgressProductQuery
+from .data_server_dispatcher import ReturnProgressDataServerQuery, ReturnProgressProductQuery, ReturnProgressHtmlProductQuery
 
 
 def my_instr_factory():
@@ -20,11 +20,14 @@ def my_instr_factory():
     return_progress_query = ReturnProgressProductQuery('empty_parameters_dummy_query_return_progress',
                                                        parameters_list=[p])
 
-    query_dictionary = {'dummy': 'empty_parameters_dummy_query_return_progress'}
+    return_progress_html_query = ReturnProgressHtmlProductQuery('empty_parameters_dummy_query_return_progress_html')
+
+    query_dictionary = {'dummy': 'empty_parameters_dummy_query_return_progress',
+                        'dummy_html': 'empty_parameters_dummy_query_return_progress_html'}
 
     return Instrument('empty-async-return-progress',
                       src_query=src_query,
                       instrumet_query=instr_query,
-                      product_queries_list=[return_progress_query],
+                      product_queries_list=[return_progress_query, return_progress_html_query],
                       query_dictionary=query_dictionary,
                       data_server_query_class=ReturnProgressDataServerQuery)