29 lines
737 B
Python
29 lines
737 B
Python
"""operators module"""
|
|
|
|
from .profiles import ProfileOperator
|
|
from .bgjobs import BgJobOperator
|
|
from .cronjobs import CronJobOperator
|
|
from .crawls import CrawlOperator
|
|
from .baseoperator import K8sOpAPI
|
|
|
|
operator_classes = [ProfileOperator, BgJobOperator, CronJobOperator, CrawlOperator]
|
|
|
|
|
|
# ============================================================================
|
|
def init_operator_api(app, *args):
|
|
"""registers webhook handlers for metacontroller"""
|
|
|
|
k8s = K8sOpAPI()
|
|
|
|
operators = []
|
|
for cls in operator_classes:
|
|
oper = cls(k8s, *args)
|
|
oper.init_routes(app)
|
|
operators.append(oper)
|
|
|
|
@app.get("/healthz", include_in_schema=False)
|
|
async def healthz():
|
|
return {}
|
|
|
|
return k8s
|