Skip to content

Commit

Permalink
[IMP] connector_extension: use_data is a new parameter to use the ext…
Browse files Browse the repository at this point in the history
…ernal data or not
  • Loading branch information
KNVx authored and eantones committed Jan 9, 2024
1 parent f526089 commit dd75dc6
Showing 1 changed file with 18 additions and 4 deletions.
22 changes: 18 additions & 4 deletions connector_extension/components/importer.py
Original file line number Diff line number Diff line change
Expand Up @@ -239,7 +239,7 @@ class ConnectorExtensionGenericBatchImporter(AbstractComponent):

_usage = "batch.importer"

def run(self, domain=None):
def run(self, domain=None, use_data=True):
"""Run the synchronization"""
if domain is None:
domain = []
Expand All @@ -257,10 +257,24 @@ def run(self, domain=None):
total_items -= chunk_size
else:
sync_date = fields.Datetime.now()
data, len_items = self.backend_adapter.search_read(domain)
if use_data:
data, len_items = self.backend_adapter.search_read(domain)

def _import_record(x):
return self._import_record(
self.binder_for().dict2id(x, in_field=False),
sync_date,
external_data=x,
)

else:
data, len_items = self.backend_adapter.search(domain)

def _import_record(x):
return self._import_record(x, sync_date)

for d in data:
external_id = self.binder_for().dict2id(d, in_field=False)
self._import_record(external_id, sync_date, external_data=d)
_import_record(d)

def _import_chunk(self, domain, offset, chunk_size):
raise NotImplementedError
Expand Down

0 comments on commit dd75dc6

Please sign in to comment.