Skip to content

Commit

Permalink
add kwargs in fetch method
Browse files Browse the repository at this point in the history
  • Loading branch information
marcocapozzoli committed Mar 27, 2024
1 parent ec77412 commit fbf303c
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions hyperon_das/query_engines.py
Original file line number Diff line number Diff line change
Expand Up @@ -533,8 +533,11 @@ def fetch(
if not host and not port:
host = self.query_engine.host
port = self.query_engine.port
kwargs['running_on_server'] = True
documents = self.cache_manager.fetch_data(
query=query, host=host, port=port, server=self.remote_das
kwargs.update(
{
'running_on_server': True,
'server': self.remote_das,
}
)
documents = self.cache_manager.fetch_data(query=query, host=host, port=port, **kwargs)
self.cache_manager.bulk_insert(documents)

0 comments on commit fbf303c

Please sign in to comment.