Internal implementation of `pipeline_output`.

Create a MultiIndex for a pipeline output. Parameters ---------- dates : pd.DatetimeIndex Row labels for ``mask``. asset

Pop entries from the `kwargs` passed to cls.__new__ based on the values in `cls.params`. Parameters ----------

Return the "principal" type for a ComputableTerm. This returns either Filter, Factor, or Classifier, depending on the type o

Generate 'raw' data that encodes information about the asset. See docstring for a description of the data format.

Draw `g` as a graph to `out`, in format `format`. Parameters ---------- g : zipline.pipeline.graph.TermGraph Graph to render

Roll window worth of data up to position zero. Save the effort of having to expensively roll at each iteration

Roll window worth of data up to position zero. Save the effort of having to expensively roll at each iteration

Shared core for ``run_pipeline`` and ``run_chunked_pipeline``.

Retrieve the most recent symbol for a set of sids. Parameters ---------- sid_group : iterable[int] The sids to lo

Sort a set, sorting ``None`` before other elements, if present.

Split out currency columns from OHLCV columns. Parameters ---------- columns : list[zipline.pipeline.data.BoundColumn]

Split out the symbol: sid mappings from the raw data. Parameters ---------- df : pd.DataFrame The dataframe with multiple rows fo

Convert raw computed pipeline results into a DataFrame for public APIs. Parameters ---------- terms : dict[str -> Te

Union entries in ``iterables`` into a set.

You almost certainly shouldn't use this.

Verify that the stored rank method is valid.

Validate that asset identifiers are contained in the daily bars. Parameters ---------- assets : array-like[int] Th

Verify that the values passed to compute_chunk are well-formed.

Make sure a passed column is our column.

Write /country/currency

Write /country/data

Write content of /data.

Write /country/index.

Write content of /index.

Internal implementation of write. `iterator` should be an iterator yielding pairs of (asset, ctable).

Write /country/lifetimes

Register a callback to be executed during tearDownClass. Parameters ---------- callback : callable The c

A note about cost-basis in zipline: all positions are considered to share a cost basis, even if they were executed in different

Advances the current dt skipping non market days and minutes.

Check if an asset was alive in the range from start to end. Parameters ---------- asset : Asset The asset to check start

Return an iterator of all pairs, (v0, v1) from values such that `pred(v0, v1) == True` Parameters ---------- values : iterable

Return all valid sub-indices of a pandas Index.

Apply a function but emulate the API of an asynchronous call. Parameters ---------- f : callable The function to

Assert that an event meets the protocol for datasource outputs.

Assert that two pipelines produce the same results.

Assert that ``expected`` matches the result. Parameters ---------- result : str The string to search. expected : str or compi

Yield classes in the order that methods should be looked up from the base classes of an object.

Bind a `Column` object to its name.

Get a boolean value from the environment, making a reasonable attempt to convert "truthy" values to True and "falsey" values to False. S

Builds a dict mapping group keys to maps of keys to lists of OwnershipPeriods, from a db table.

Generate test cases for the type of asset finder specific by asset_finder_type for test_lookup_generic.

Format a bulleted list of values. Parameters ---------- items : sequence The items to make a list. indent : int, optional

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

Calculate the ratios to apply to equities when looking back at pricing history so that the price is smoothed over the ex_date, when t

Given a date, find that day's open and period end (open + offset).

Given a dt, find that day's close and period start (close - offset).

Cancel all open orders for a given asset.

Cancel an open order. Parameters ---------- order_param : str or Order The order_id or order object to cancel.

Compute indices of values in ``a`` that differ from the previous value. Parameters ---------- a : np.ndarray The array on wh

Check the expected result of column.latest from a pipeline.

Given an order and a trade event, return a tuple of (stop_reached, limit_reached). For market orders, will return (False, Fal

Check that two 1d arrays of sids are equal

Update internal state based on price triggers and the trade event's price.

Construct an iterable of length-1 strings beginning with `start` and ending with `stop`. Parameters ---------- start : str