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.

Sign up for GitHub

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

Miscellaneous improvements #8

Merged
merged 9 commits into from
Sep 19, 2024
Merged

Miscellaneous improvements #8

Changes from all commits
Commits
Show all changes
9 commits
Select commit Hold shift + click to select a range
f9bc3d2
Miscellaneous improvements
atsag Jul 11, 2024
4cede0c
Merge remote-tracking branch 'origin/main'
atsag Jul 11, 2024
d8b9319
Readme file location correction
atsag Jul 11, 2024
b31ef9a
Merge remote-tracking branch 'refs/remotes/master/main'
atsag Jul 19, 2024
0ba7c36
Environment variable correction
atsag Jul 22, 2024
a7d7420
Merge remote-tracking branch 'origin/main'
atsag Sep 13, 2024
3ac146b
Small configuration file improvements
atsag Sep 16, 2024
7622c62
Corrected the publishing of forecasts for a particular application
atsag Sep 19, 2024
cf977b2
Merge branch 'eu-nebulous:main' into main
atsag Sep 19, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 3 additions & 2 deletions exponential-smoothing-predictor/src/runtime/utilities/PredictionPublisher.py
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,11 +1,12 @@
from exn import core
from runtime.operational_status.EsPredictorState import EsPredictorState


class PredictionPublisher(core.publisher.Publisher):
metric_name = ""
def __init__(self,application_name,metric_name):
super().__init__('publisher_'+application_name+'-'+metric_name, 'eu.nebulouscloud.preliminary_predicted.'+metric_name, True,True)
super().__init__('publisher_'+application_name+'-'+metric_name, 'eu.nebulouscloud.preliminary_predicted.'+EsPredictorState.forecaster_name+"."+metric_name, True,True)
self.metric_name = metric_name

def send(self, body={}, application=""):
super(PredictionPublisher, self).send(body)
super(PredictionPublisher, self).send(body, application)