Skip to content
Snippets Groups Projects
Commit 1683426a authored by Bryan BRANCOTTE's avatar Bryan BRANCOTTE
Browse files

add pre_process

parent d9d86350
No related branches found
No related tags found
No related merge requests found
Pipeline #85731 passed
......@@ -76,6 +76,9 @@ class ImportTask(object):
def post_process(self):
pass
def pre_process(self):
pass
def _process_rows(self, rows, progress=None):
for row in rows:
try:
......@@ -105,6 +108,7 @@ class ImportTask(object):
def _run_import_loop(self):
self.open_data_source()
self.count_source()
self.pre_process()
if self.progress_bar is True:
with click.progressbar(length=self.source_count,
label='Importing ' + self.description + ' (' + str(self.source_count) + ' rows to process).') as progress:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment