alessandrolollo / prefect-stitch Goto Github PK

Using the code as instructed, I get the TypeError: missing a required argument: 'credentials. See code below.

from prefect import flow
from prefect_stitch.tasks import (
start_replication_job
)

@flow
def run_s3_stitch_job():
start_replication_job(
access_token="xxx",
source_id=xxx
)

if name == "main":
run_s3_stitch_job()