Riley Hun
08/11/2020, 6:48 PMwith Flow(
"Thinknum_ETL",
schedule=schedule
) as flow:
token = token_task(
version=version
)
t = print_value(token)
with open('./build_creds.json') as f:
envs = json.load(f)
storage = Docker(
image_name='flows-storage',
image_tag='latest',
dockerfile='./dockerfiles/thinknum/Dockerfile',
local_image=True,
env_vars=envs
)
storage.build()
flow.storage = storage
security = Security(tls_ca_file='certs/myca.pem',
tls_client_cert='certs/myca.pem',
tls_client_key='certs/mykey.pem',
require_encryption=True)
flow.environment.executor = DaskExecutor(address='<IP ADDRESS>', client_kwargs={'security': security})
flow.register(build=False)
Jenny
08/11/2020, 6:53 PMRiley Hun
08/11/2020, 6:55 PMJenny
08/11/2020, 7:03 PMfrom prefect import Flow
my_flow = Flow.load('name_of_flow_OR_abs_path')
my_flow.run()
Riley Hun
08/11/2020, 7:48 PMNo such file or directory: '/Users/rihun/.prefect/flows/thinknum-etl.prefect'
Jenny
08/11/2020, 7:52 PMRiley Hun
08/11/2020, 8:05 PMflow.register()
, I tried flow.run_agent()
. Will try again.Jenny
08/11/2020, 8:41 PMRiley Hun
08/11/2020, 8:45 PM[server]
[server.ui]
graphql_url = "<http://localhost:4200/graphql>"
Jenny
08/11/2020, 8:47 PMRiley Hun
08/11/2020, 8:48 PMFailed to load and execute Flow's environment: FileNotFoundError(2, 'No such file or directory')
Jenny
08/11/2020, 10:50 PMRiley Hun
08/11/2020, 11:15 PMSubmitted for execution: Container ID: 4f32ff2618bbedf51826a325f5517ddd9e610dedff074bb3bc9f7d35a8e1d2e5