File tree Expand file tree Collapse file tree 1 file changed +12
-13
lines changed
Expand file tree Collapse file tree 1 file changed +12
-13
lines changed Original file line number Diff line number Diff line change @@ -139,26 +139,25 @@ def apply_to_dataset(
139139 out = None
140140 if parallelize_with_dask :
141141 (wired_events ,) = _pack_meta_to_wire (events )
142- out = dask .delayed (
143- lambda : lz4 .frame .compress (
144- cloudpickle .dumps (
145- partial (_apply_analysis_wire , analysis , wired_events )()
146- ),
147- compression_level = 6 ,
148- )
149- )()
142+ out = (
143+ dask .delayed (
144+ lambda : lz4 .frame .compress (
145+ cloudpickle .dumps (
146+ partial (_apply_analysis_wire , analysis , wired_events )()
147+ ),
148+ compression_level = 6 ,
149+ )
150+ )(),
151+ )
150152 dask .base .function_cache .clear ()
151153 else :
152154 out = analysis (events )
155+ if not isinstance (out , tuple ):
156+ out = (out ,)
153157
154158 if report is not None :
155- < << << << HEAD
156- return out , report
157- return (out ,)
158- == == == =
159159 return events , out , report
160160 return events , out
161- >> >> >> > aae802b3 (provide interface for serializing taskgraphs to / from disk )
162161
163162
164163def apply_to_fileset (
You can’t perform that action at this time.
0 commit comments