from prefect import flow from prefect_shell import shell_run_command @flow(name_=_"Run Meltano Google") def run_meltano_google(): command = "meltano --log-level=debug elt tap-google-ads target-postgres--google --state-id=google-ads-to-postgres" return shell_run_command(command_=_command, helper_command_=_"cd ~/agendapro-data-integration/meltano/;source .venv/bin/activate;", return_all_=_True) if name == "__main__": run_meltano_google().run()