kvh/snapflow-fred

FRED module for snapflow

FRED module for the snapflow framework.

Install

pip install snapflow-fred or poetry add snapflow-fred

Example

from snapflow import Graph, produce
import snapflow_fred

g = graph()

# Initial graph
gdp = g.create_node(
    "fred.import_observations",
    params={"api_key": "xxxxx", "series_id": "gdp"},
)
blocks = produce(gdp, env=env, modules=[fred])
print(blocks[0].as_records())