Unverified Commit 3fa381df authored by Sebastian Schüpbach's avatar Sebastian Schüpbach
Browse files

remove custom max records limit

parent 052eb2ca
Pipeline #16989 canceled with stages
......@@ -275,7 +275,7 @@ class MediametadataToDB:
reporter = Reporter()
try:
while True:
consumer.poll(max_records=100)
consumer.poll()
for recordNo, recordsJson in enumerate(consumer):
records_json_data = recordsJson.value['@graph']
record_id = _get_record_id(records_json_data)
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment