Skip to content

kafka2frame: fix issue where frame directories were not created in time

This prevents a FileNotFoundError upon trying to clean out files where the directory wasn't created yet. This was because there was a loop where directories per detector when frames are first written to disk, but the cleaning routine was triggered for all detectors after the first iteration. This fix puts the two in sync so that directories are always created first.

Merge request reports