I would change:
df = open(ZstdDecompressorStream, filepath) do stream
return munge_csv(stream)
end
to:
local df = open(ZstdDecompressorStream, filepath) do stream
return munge_csv(stream)
end
to make sure df isn’t getting captured from an upper scope, when you do df = vcat(dfs...).