Pipeline Mode

from pfeed.feeds import BybitFeed


(
    BybitFeed(use_prefect=True, pipeline_mode=True)
    .download(
        products=['BTC_USDT_PERP'],
        start_date='2024-01-01',
        end_date='2024-01-02',
    )
    .load(storage='local')
)