astro.dataframes.pandas

Module Contents

Classes

PandasDataframe

Pandas-compatible dataframe class that can be serialized and deserialized into XCom by Airflow 2.5

Attributes

logger

astro.dataframes.pandas.logger
class astro.dataframes.pandas.PandasDataframe(data=None, index=None, columns=None, dtype=None, copy=None)

Bases: pandas.DataFrame

Pandas-compatible dataframe class that can be serialized and deserialized into XCom by Airflow 2.5

Parameters:

  • index (pandas._typing.Axes | None) –

  • columns (pandas._typing.Axes | None) –

  • dtype (pandas._typing.Dtype | None) –

  • copy (bool | None) –

version: ClassVar[int] = 1
serialize()
static deserialize(data, version)
Parameters:

  • data (dict) –

  • version (int) –

classmethod from_pandas_df(df)
Parameters:

df (pandas.DataFrame) –

Return type:

pandas.DataFrame | PandasDataframe