Zach Schumacher
05/06/2022, 8:03 PMCloudFlowRunner
so that we can initialize sentry and datadog as early as possible, as well as flush our statsd buffer to track metrics.
it seems like the place i'd expect it to read from the env var is hardcoded tho https://github.com/PrefectHQ/prefect/blob/master/src/prefect/agent/kubernetes/agent.py#L562-L586Zach Schumacher
05/06/2022, 8:04 PMclass FlowRunner(CloudFlowRunner): # pragma: no cover
def run(self, *args, **kwargs):
<http://logger.info|logger.info>("Flow start")
try:
tasks.init()
result = super().run(*args, **kwargs)
finally:
statsd.flush()
return result
Zach Schumacher
05/06/2022, 8:04 PMZach Schumacher
05/06/2022, 8:06 PMAnna Geller
Anna Geller
Anna Geller
PREFECT__ENGINE__FLOW_RUNNER__DEFAULT_CLASS
Zach Schumacher
05/06/2022, 8:27 PMJoshua Massover
05/06/2022, 8:28 PMAnna Geller
Kevin Kho
Kevin Kho
Zach Schumacher
05/06/2022, 9:00 PMZach Schumacher
05/06/2022, 9:00 PMKevin Kho
Zach Schumacher
05/06/2022, 9:00 PM