diff --git a/datapusher/jobs.py b/datapusher/jobs.py index 76828b7..b0b9b9c 100644 --- a/datapusher/jobs.py +++ b/datapusher/jobs.py @@ -508,8 +508,9 @@ def row_iterator(): for i, chunk in enumerate(chunky(result, CHUNK_INSERT_ROWS)): records, is_it_the_last_chunk = chunk count += len(records) - logger.info('Saving chunk {number} {is_last}'.format( - number=i, is_last='(last)' if is_it_the_last_chunk else '')) + if is_it_the_last_chunk: + logger.info('Saving records {number} - {record}'.format( + number=1, record=count)) send_resource_to_datastore(resource, headers_dicts, records, is_it_the_last_chunk, api_key, ckan_url)