diff --git a/servicex_databinder/__init__.py b/servicex_databinder/__init__.py index 82f1110..cd117ef 100644 --- a/servicex_databinder/__init__.py +++ b/servicex_databinder/__init__.py @@ -2,7 +2,7 @@ from .servicex_databinder import DataBinder -__version__ = '0.2.4' +__version__ = '0.2.5' logging.basicConfig(format="%(levelname)s - %(message)s") logging.getLogger(__name__).setLevel(logging.INFO) \ No newline at end of file diff --git a/servicex_databinder/frontend.py b/servicex_databinder/frontend.py index 8fd4e73..34cc7df 100644 --- a/servicex_databinder/frontend.py +++ b/servicex_databinder/frontend.py @@ -46,6 +46,7 @@ def get_servicex_data(self, test_run=False): async def bound_get_data(sem, sx_ds, query): async with sem: return await sx_ds.get_data_parquet_async(query) + # return await sx_ds.get_data_parquet_async(query, 'test') # When fix in ServiceX Frontend async def _get_my_data(): sem = asyncio.Semaphore(50) # Limit maximum concurrent ServiceX requests @@ -55,7 +56,7 @@ async def _get_my_data(): for request in self._servicex_requests: sx_ds = ServiceXDataset(dataset=request['dataset'], \ backend_name=self._config['General']['ServiceXBackendName'], \ - image=transformer_image, \ + # image=transformer_image, \ session_generator=session, \ ignore_cache=ignoreCache) query = request['query']