Pedro Machado
11/13/2020, 6:21 AMidempotency_key=flow.serialized_hash()
when registering a flow. The hash is changing even when nothing has changed in the flow. Any ideas?Pedro Machado
11/13/2020, 6:22 AMimport prefect
from prefect import task, Flow
from prefect.environments.storage import Docker
@task
def hello_task():
logger = prefect.context.get("logger")
<http://logger.info|logger.info>("Hello, Docker!")
flow = Flow("hello-docker", tasks=[hello_task])
flow.storage = Docker()
idempotency_key = flow.serialized_hash()
print(idempotency_key)
flow.register(project_name="myproject", idempotency_key=idempotency_key)
Every time I run this I get different resultsnicholas
idempotency_key
to prevent subsequent registrations when you know changes haven't been made.