diff --git a/lisa/trace.py b/lisa/trace.py index 90828baa4b6b1d9b1dcfbd4ec02a933e1900bb19..e3b44d5f704724c04e8646a8bf6e2275805391c2 100644 --- a/lisa/trace.py +++ b/lisa/trace.py @@ -4242,6 +4242,10 @@ class _TraceCache(Loggable): pass raise else: + # Ensure we actually trigger a file read, in case we are trying + # to interpret as parquet something that is not parquet + df.clear().collect() + df = _LazyFrameOnDelete.attach_file_cleanup(df, [hardlink_base]) return df