def load_raw_data(assets, dates, data_query_time, data_query_tz, expr, odo_kwargs, checkpoints=None):
 (lower_dt, upper_dt) = normalize_data_query_bounds(dates[0], dates[(-1)], data_query_time, data_query_tz)
 raw = ffill_query_in_range(expr, lower_dt, upper_dt, checkpoints=checkpoints, odo_kwargs=odo_kwargs)
 sids = raw[SID_FIELD_NAME]
 raw.drop(sids[(~ sids.isin(assets))].index, inplace=True)
 if (data_query_time is not None):
  normalize_timestamp_to_query_time(raw, data_query_time, data_query_tz, inplace=True, ts_field=TS_FIELD_NAME)
 return raw

def load_raw_data ( assets , dates , data_query_time , data_query_tz , expr , odo_kwargs , checkpoints = None ) : ( lower_dt , upper_dt ) = normalize_data_query_bounds ( dates [ 0 ] , dates [ ( - 1 ) ] , data_query_time , data_query_tz ) raw = ffill_query_in_range ( expr , lower_dt , upper_dt , checkpoints = checkpoints , odo_kwargs = odo_kwargs ) sids = raw [ SID_FIELD_NAME ] raw . drop ( sids [ ( ~ sids . isin ( assets ) ) ] . index , inplace = True ) if ( data_query_time is not None ) : normalize_timestamp_to_query_time ( raw , data_query_time , data_query_tz , inplace = True , ts_field = TS_FIELD_NAME ) return raw
given an expression representing data to load .