Function run_capital_flow 

pub async fn run_capital_flow(
    gateway: &str,
    symbol: &str,
    period_type: i32,
    begin: Option<&str>,
    end: Option<&str>,
    format: OutputFormat,
) -> Result<()>