Skip to content

ligo/scald/io/kafka.py: set key to empty list if not given, not None

Rebecca Ewing requested to merge rebecca.ewing/ligo-scald:fix-no-tags-bug into master

This fixes a bug that causes the scald aggregate job to fail with the error:

File "/usr/lib/python3.6/site-packages/ligo/scald/io/kafka.py", line 100, in query
    tuple(key),
TypeError: 'NoneType' object is not iterable

in the case that scald receives messages without any keys.

Merge request reports

Loading