diff --git a/cdci_data_analysis/plugins/dummy_plugin/data_server_dispatcher.py b/cdci_data_analysis/plugins/dummy_plugin/data_server_dispatcher.py index 3729ae699..2cdab0144 100644 --- a/cdci_data_analysis/plugins/dummy_plugin/data_server_dispatcher.py +++ b/cdci_data_analysis/plugins/dummy_plugin/data_server_dispatcher.py @@ -187,7 +187,8 @@ def __init__(self, name, parameters_list=None): super().__init__(name, return_progress=True, parameters_list=parameters_list) def get_dummy_progress_run(self, instrument, config=None,**kwargs): - return [] + p_value = instrument.get_par_by_name('p').value + return [p_value] class EmptyProductQuery(ProductQuery): diff --git a/cdci_data_analysis/plugins/dummy_plugin/empty_async_return_progress_instrument.py b/cdci_data_analysis/plugins/dummy_plugin/empty_async_return_progress_instrument.py new file mode 100644 index 000000000..4855cb722 --- /dev/null +++ b/cdci_data_analysis/plugins/dummy_plugin/empty_async_return_progress_instrument.py @@ -0,0 +1,31 @@ +from __future__ import absolute_import, division, print_function + +__author__ = "Gabriele Barni" + +from cdci_data_analysis.analysis.instrument import Instrument +from cdci_data_analysis.analysis.queries import SourceQuery, InstrumentQuery, Float, Name + +from .data_server_dispatcher import DataServerQuery, DataServerNumericQuery, ReturnProgressProductQuery + + +def my_instr_factory(): + src_query = SourceQuery('src_query') + + # empty query + instr_query = InstrumentQuery(name='empty_async_return_progress_instrument_query', + input_prod_list_name='scw_list', + catalog=None, + catalog_name='user_catalog') + + p = Float(value=10., name='p', units='W') + return_progress_query = ReturnProgressProductQuery('empty_parameters_dummy_query_return_progress', + parameters_list=[p]) + + query_dictionary = {'dummy': 'empty_parameters_dummy_query_return_progress'} + + return Instrument('empty-async-return-progress', + src_query=src_query, + instrumet_query=instr_query, + product_queries_list=[return_progress_query], + query_dictionary=query_dictionary, + data_server_query_class=DataServerQuery)