diff --git a/zipline/pipeline/loaders/blaze/core.py b/zipline/pipeline/loaders/blaze/core.py index 925faddf..06b59cf4 100644 --- a/zipline/pipeline/loaders/blaze/core.py +++ b/zipline/pipeline/loaders/blaze/core.py @@ -1175,7 +1175,11 @@ def get_materialized_checkpoints(checkpoints, colnames, lower_dt, odo_kwargs): """ if checkpoints is not None: ts = checkpoints[TS_FIELD_NAME] - checkpoints_ts = odo(ts[ts <= lower_dt].max(), pd.Timestamp) + checkpoints_ts = odo( + ts[ts <= lower_dt].max(), + pd.Timestamp, + **odo_kwargs + ) if pd.isnull(checkpoints_ts): materialized_checkpoints = pd.DataFrame(columns=colnames) lower = None diff --git a/zipline/pipeline/loaders/earnings_estimates.py b/zipline/pipeline/loaders/earnings_estimates.py index b28991d4..896560c1 100644 --- a/zipline/pipeline/loaders/earnings_estimates.py +++ b/zipline/pipeline/loaders/earnings_estimates.py @@ -532,7 +532,7 @@ class EarningsEstimatesLoader(PipelineLoader): level=0, inplace=True, ) - stacked_last_per_qtr = stacked_last_per_qtr.sort( + stacked_last_per_qtr = stacked_last_per_qtr.sort_values( EVENT_DATE_FIELD_NAME, ) stacked_last_per_qtr[EVENT_DATE_FIELD_NAME] = pd.to_datetime(