The close field's aggregation returns the latest close at the given dt. If the close for the given dt is `nan`, the most rece

A preprocessing decorator that coerces inputs of a given type by passing them to a callable. Parameters ---------- from : type o

Collect split adjustments that occur after the split-adjusted-asof-date. Each adjustment needs to be applied to all dates on

Collect split adjustments that occur before the split-adjusted-asof-date. All those adjustments must first be UN-applied at t

Parameters ---------- frames : dict[str, pd.DataFrame] A dict mapping each OHLCV field to a dataframe with a row for each

Compute any pipelines attached with eager=True.

Adapt OHLCV columns into uint32 columns. Parameters ---------- cols : dict A dict mapping each column name (open, high, low, clos

Add entries to the dictionary of columns to adjustments for the given sid and the given quarter. Parameters --------

Create a new pipeline domain with a simple date_range index.

Build a zipline data bundle from the directory with csv files.

Return the number of data points up to and including the provided day.

The root directory for zipline data files. Parameters ---------- environ : dict, optional An environment dict to forward to

Given a datashape type, return the associated numpy type. Maps datashape's DateTime type to numpy's `datetime64[ns]` dtype, since the num

Utility to generate a stream of dates.

Returns the date index and sid columns shared by a list of dataframes, ensuring they all match. Parameters ---------- frames : l

Decrement in-edges for ``term`` after computation. Parameters ---------- term : zipline.pipeline.Term Th

Get a default country_code to use for fetch_csv symbol lookups. This will be used to disambiguate symbol lookups for fetch_csv calls

Handle data function shared between test algos.

Handle data function shared between test algos.

Initialize function shared between test algos.

Initialize function shared between test algos.

Get a default pipeline domain for algorithms running on ``calendar``. This will be used to infer a domain for pipelines that only us

Factory function for making DelegatingHooks methods.

Register the number of shares we held at this dividend's ex date so that we can pay out the correct amount on the dividend's pay date

Given a list of dividends whose ex_dates are all the next trading day, calculate and store the cash and/or stock payments to be paid on

Register the number of shares we held at this dividend's ex date so that we can pay out the correct amount on the dividend's pay date

Return the input as a numpy ndarray. This is a no-op if the input is already an ndarray. If the input is an adjusted_array, this extrac

Normalize a time. If the time is tz-naive, assume it is UTC.

Preprocessing decorator that verifies inputs are elements of some expected collection. Examples -------- >>> @expect_element(x=(

Compute the expected data (without adjustments) for the given window, k, and closes array. This uses talib.BBANDS to generate the exp

Get expected progress after finishing a chunk ending at ``chunk_end``.

Construct a CachedObject that's expired at any time.

Convert a click.option call into a click.Option object. Parameters ---------- option : decorator A click.option decorator. R

Equivalent to dts.get_loc(dt, method='ffill'), but with reasonable microperformance.

Fetch WIKI Prices data table from Quandl

Forward fill values in a DataFrame with special logic to handle cases that pd.DataFrame.ffill cannot and cast columns to appropriate types.

Query a blaze expression in a given time range properly forward filling from values that fall before the lower date. Parameters ---------

Fold a function over a sequence with right associativity. Parameters ---------- f : callable[any, any] The function to reduce the

Template ``formatters`` into ``docstring``. Parameters ---------- owner_name : str The name of the function or class whose d