Skip to content

Commit

Permalink
Fix Python code formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
ndebuhr committed Aug 25, 2022
1 parent 0cf67e4 commit ab40199
Show file tree
Hide file tree
Showing 7 changed files with 14 additions and 30 deletions.
7 changes: 2 additions & 5 deletions deployer/github/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,10 +29,7 @@
raise ValueError("No CELERY_BROKER environment variable set")

app = Flask(__name__)
trace = observability.setup(
flask_app=app,
requests_enabled=True
)
trace = observability.setup(flask_app=app, requests_enabled=True)

tasks = Celery(
"tasks",
Expand Down Expand Up @@ -236,4 +233,4 @@ def poll_for_conclusion(

@app.route("/metrics")
def metrics():
return generate_latest()
return generate_latest()
10 changes: 4 additions & 6 deletions deployer/github/metrics.py
Original file line number Diff line number Diff line change
@@ -1,22 +1,21 @@
from prometheus_client import Gauge

def define_metrics(tasks):

def define_metrics(tasks):
def deployments_scheduled():
i = tasks.control.inspect()
return sum([len(i.scheduled()[worker]) for worker in i.scheduled().keys()])


deployments_scheduled_metric = Gauge(
"isidro:deployments_scheduled", "Deployments that have an ETA or are scheduled for later processing"
"isidro:deployments_scheduled",
"Deployments that have an ETA or are scheduled for later processing",
)
deployments_scheduled_metric.set_function(deployments_scheduled)

def deployments_active():
i = tasks.control.inspect()
return sum([len(i.active()[worker]) for worker in i.active().keys()])


deployments_active_metric = Gauge(
"isidro:deployments_active", "Deployments that are currently active"
)
Expand All @@ -26,8 +25,7 @@ def deployments_reserved():
i = tasks.control.inspect()
return sum([len(i.reserved()[worker]) for worker in i.reserved().keys()])


deployments_reserved_metric = Gauge(
"isidro:deployments_reserved", "Deployments that have been claimed by workers"
)
deployments_reserved_metric.set_function(deployments_reserved)
deployments_reserved_metric.set_function(deployments_reserved)
5 changes: 2 additions & 3 deletions keywords/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -13,9 +13,8 @@
POS_TAGS = ["PROPN", "NOUN", "VERB", "NUM", "SYM", "X"]

app = Flask(__name__)
observability.setup(
flask_app=app
)
observability.setup(flask_app=app)


class Keywords:
def __init__(self, request):
Expand Down
5 changes: 1 addition & 4 deletions orchestration/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -49,10 +49,7 @@
raise ValueError("No REPEATER_HOST environment variable set")

app = Flask(__name__)
trace = observability.setup(
flask_app=app,
requests_enabled=True
)
trace = observability.setup(flask_app=app, requests_enabled=True)


class Orchestration:
Expand Down
6 changes: 2 additions & 4 deletions repeater/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -12,10 +12,8 @@
raise ValueError("No RESPONDER_HOST environment variable set")

app = Flask(__name__)
observability.setup(
flask_app=app,
requests_enabled=True
)
observability.setup(flask_app=app, requests_enabled=True)


class Repeater:
def __init__(self, request):
Expand Down
5 changes: 1 addition & 4 deletions responder/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -18,10 +18,7 @@
raise ValueError("No MATTERMOST_DOMAIN environment variable set")

app = Flask(__name__)
observability.setup(
flask_app=app,
requests_enabled=True
)
observability.setup(flask_app=app, requests_enabled=True)


class Responder:
Expand Down
6 changes: 2 additions & 4 deletions tasks/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,10 +16,8 @@
raise ValueError("No DEPLOYER_GITHUB_HOST environment variable set")

app = Flask(__name__)
observability.setup(
flask_app=app,
requests_enabled=True
)
observability.setup(flask_app=app, requests_enabled=True)


class Task:
def __init__(self, request):
Expand Down

0 comments on commit ab40199

Please sign in to comment.