Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Dead processes metrics #53

Merged
merged 4 commits into from
Apr 12, 2024
Merged

Dead processes metrics #53

merged 4 commits into from
Apr 12, 2024

Conversation

mikha1lov
Copy link

@mikha1lov mikha1lov commented Mar 22, 2024

  • Counting processes
  • Sending last pack of metrics after app was stopped

@mikha1lov mikha1lov changed the title Dead processes metrics WIP: Dead processes metrics Mar 22, 2024
@@ -30,13 +30,15 @@ def __init__(self):
self.queue_sizes = MetricsItems()
self.tasks_stats = TasksStats()
self.memory_usage = MetricsItems()
self.dead_processes_count = MetricsItems()
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

word 'count' in dead_processes_count seems like unnecessary, it will be simplier id you make just self.dead_processes

Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Now it is processes_stats

@mikha1lov mikha1lov changed the title WIP: Dead processes metrics Dead processes metrics Apr 10, 2024

def add_dead_process(self):
self.dead += 1
self.running = 0
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

self.running = 0
looks like a crutch, can we deal without need self.running = 0, maybe we dont need stop metcrics manager when we stoppping flow

@@ -25,6 +25,7 @@
from .metrics.collect import Collector, TasksStats
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Please updade CHANGELOG and version

aqueduct/flow.py Show resolved Hide resolved
@bugrimov bugrimov merged commit 877152b into avito-tech:main Apr 12, 2024
1 check passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

None yet

2 participants