@@ -429,13 +429,16 @@ def dfuse(df_spec):
429429 self .logger .info ('merging %s with %s on %s into %s' , base , ref , on , out )
430430 if not is_numeric_dtype (dfs [base ][on ]):
431431 self .logger .info ('exploding dataframe %s on variable %s' , base , on )
432- dfs [out ] = dfmerge (dfs [base ].explode (on ), dfs [ref ], left_on = ['df' , on ], suffixes = (f'_{ base } ' , None ), right_index = True )
432+ dfs [out ] = dfmerge (
433+ exploded_df , dfs [ref ], left_on = ['df' , on ], suffixes = (f'_{ base } ' , None ), right_index = True )
433434 else :
434- dfs [out ] = dfmerge (dfs [base ], dfs [ref ], left_on = ['df' , on ], suffixes = (f'_{ base } ' , None ), right_index = True )
435+ dfs [out ] = dfmerge (
436+ dfs [base ], dfs [ref ], left_on = ['df' , on ], suffixes = (f'_{ base } ' , None ), right_index = True )
435437 else :
436438 var = self .df_read [ref ]['index' ]
437439 self .logger .info ('merging %s with %s on %s (default) into %s' , base , ref , var , out )
438- dfs [out ] = dfmerge (dfs [base ], dfs [ref ], left_on = ['df' , var ], suffixes = (f'_{ base } ' , None ), right_index = True )
440+ dfs [out ] = dfmerge (
441+ dfs [base ], dfs [ref ], left_on = ['df' , var ], suffixes = (f'_{ base } ' , None ), right_index = True )
439442 if 'extra' in m_spec :
440443 self .logger .debug (' %s -> extra' , out )
441444 for col_name , col_val in m_spec ['extra' ].items ():
0 commit comments