universalrobots/job_orchestrator_service
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Loaded k8s extension

Browse Source
This commit is contained in:
Pünkösd Marcell 2021-04-18 15:13:50 +02:00
parent e8f5f26afa
commit bee6ccf09c
3 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
job_orchestrator_service/app.py
View File

@ -4,7 +4,7 @@ import sentry_sdk
from sentry_sdk.integrations.flask import FlaskIntegration from sentry_sdk.integrations.flask import FlaskIntegration
from flask import Flask from flask import Flask
from utils import register_all_error_handlers from utils import register_all_error_handlers, k8s
# import views # import views
from views import JobView from views import JobView
@ -23,6 +23,9 @@ if Config.SENTRY_DSN:
# create flask app # create flask app
app = Flask(__name__) app = Flask(__name__)
app.config.from_object(Config) app.config.from_object(Config)
k8s.init_app(app)
register_all_error_handlers(app) register_all_error_handlers(app)
# register views # register views

1
job_orchestrator_service/utils/__init__.py
View File

@ -1,3 +1,4 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
from .require_decorators import json_required from .require_decorators import json_required
from .error_handlers import register_all_error_handlers from .error_handlers import register_all_error_handlers
from .kubernetes_adapter import FlaskKubernetes, k8s

3
job_orchestrator_service/utils/kubernetes_adapter.py
View File

@ -34,3 +34,6 @@ class FlaskKubernetes:
@property @property
def corev1api(self) -> kubernetes.client.CoreV1Api: def corev1api(self) -> kubernetes.client.CoreV1Api:
return kubernetes.client.CoreV1Api(self.connection) return kubernetes.client.CoreV1Api(self.connection)
k8s = FlaskKubernetes()