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-L586class 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
Anna Geller
05/06/2022, 8:21 PMPREFECT__ENGINE__FLOW_RUNNER__DEFAULT_CLASS
Zach Schumacher
05/06/2022, 8:27 PMJoshua Massover
05/06/2022, 8:28 PMAnna Geller
05/06/2022, 8:45 PMKevin Kho
05/06/2022, 8:56 PMZach Schumacher
05/06/2022, 9:00 PMKevin Kho
05/06/2022, 9:00 PMZach Schumacher
05/06/2022, 9:00 PM