Lawrence Finn
08/03/2021, 5:45 PMKevin Kho
Client
, but that would but extend to flow.register()
Lawrence Finn
08/03/2021, 6:17 PMos.environ["PREFECT__CLOUD__AUTH_TOKEN"] = get_prefect_token()
from prefect import task, Flow, Parameter
from prefect.schedules import IntervalSchedule
from datetime import timedelta
from prefect.storage import S3
from prefect.executors import DaskExecutor
from prefect.run_configs import KubernetesRun
from prefect.tasks.prefect import StartFlowRun
import prefect
which is kinda ugly but 🤷Kevin Kho
client = Client(api_key="...")
client.save_auth_to_disk()
which creates an auth.toml
file and then future Client()
calls would fetch that so when you do flow.register()
, it would work as it creates a client under the hood. But this would persist a file which I guess is not what you want.Lawrence Finn
08/03/2021, 6:23 PMKevin Kho
client.register()
function directly to register your Flow.Lawrence Finn
08/03/2021, 6:44 PMKevin Kho
prefect.client.client.Client.register(flow, project_name=None, build=True, set_schedule_active=True, version_group_id=None, compressed=True, no_url=False, idempotency_key=None)
Lawrence Finn
08/03/2021, 7:17 PM