class MyClass:
@classmethod
def run(cls):
cls.definition().execute_in_process()
@job()@staticmethod
def definition():
print(myop())
@op()
def myop()
return Output(True)
#FastAPI
app.get("dag/do/this")
def dosomethingendpoint():
myClass = MyClass()
myClass.run()