Channels
#prefect-community
Title
# prefect-community
z
Zach Schumacher
05/06/2022, 8:03 PMwhats the correct pattern for spinning our own cloud runner? we simply want to add some initialization to
CloudFlowRunnere.g. im trying to do this
Copy code
class 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 resulttalked briefly to @Kevin Kho about it
cc @Joshua Massover
a
Anna Geller
05/06/2022, 8:21 PM
actually, regarding Sentry, check this blog post https://source.coveo.com/2022/04/20/integrating-sentry-with-prefect-flows/
for Datadog this might be helpful https://github.com/PrefectHQ/prefect/discussions/5142
I believe you would, as you said, need to create your custom class and register it via this env variable:
Copy code
PREFECT__ENGINE__FLOW_RUNNER__DEFAULT_CLASSz
Zach Schumacher
05/06/2022, 8:27 PMbut it looks to be hard coded in that code snip i sent
j
Joshua Massover
05/06/2022, 8:28 PMthe sentry link is helpful for gathering further metadata regarding the flow and task, thank you! the solution seems like what we've settled on where we're creating an upstream init task before any of our other code runs. It would be nice is if each flow didn't need to worry about "python package level" process initialization.
a
Anna Geller
05/06/2022, 8:45 PM
this is not hard-coded afaik, I think you could override it on your run config - LMK if that's not the case and I could open an issue to investigate
k
Kevin Kho
05/06/2022, 8:56 PM
The agent overrides configs here for the CloudRunner
Maybe you can make you own agent class too haha
z
Zach Schumacher
05/06/2022, 9:00 PM🤯
think i'll wait for v2 😅
💯 1
upvote 1
k
Kevin Kho
05/06/2022, 9:00 PM
You’re on the Kubernetes agent right?
z
Zach Schumacher
05/06/2022, 9:00 PMye
6 Views