pub async fn datalake_entry_run(
aggregate_fn_id: AggregationFunction,
aggregate_fn_ctx: Option<FunctionContext>,
datalake: DataLakeCommands,
rpc_url: Option<Url>,
chain_id: Option<ChainId>,
pre_processor_output: Option<PathBuf>,
sound_run_cairo_file: Option<PathBuf>,
output_file: Option<PathBuf>,
cairo_pie_file: Option<PathBuf>,
) -> Result<()>