diff options
| author | Roy Ben Shabat <Roy.mail.net@gmail.com> | 2025-07-30 12:36:30 +0300 |
|---|---|---|
| committer | Roy Ben Shabat <Roy.mail.net@gmail.com> | 2025-07-30 12:36:30 +0300 |
| commit | 4222eddece906d6f0877022c06b853deb5068472 (patch) | |
| tree | a29b706b3a5aedb28a42b209d5bb72b0ef94d40e /Software/Visual_Studio/Tango.Telemetry/Modules/TelemetryJobRunsHistoryModule.cs | |
| parent | a802fe75f9538371004f1833e69a69b798892d0c (diff) | |
| download | Tango-4222eddece906d6f0877022c06b853deb5068472.tar.gz Tango-4222eddece906d6f0877022c06b853deb5068472.zip | |
Telemetry source.
Diffstat (limited to 'Software/Visual_Studio/Tango.Telemetry/Modules/TelemetryJobRunsHistoryModule.cs')
| -rw-r--r-- | Software/Visual_Studio/Tango.Telemetry/Modules/TelemetryJobRunsHistoryModule.cs | 61 |
1 files changed, 0 insertions, 61 deletions
diff --git a/Software/Visual_Studio/Tango.Telemetry/Modules/TelemetryJobRunsHistoryModule.cs b/Software/Visual_Studio/Tango.Telemetry/Modules/TelemetryJobRunsHistoryModule.cs deleted file mode 100644 index 0ba2935c1..000000000 --- a/Software/Visual_Studio/Tango.Telemetry/Modules/TelemetryJobRunsHistoryModule.cs +++ /dev/null @@ -1,61 +0,0 @@ -using System; -using System.Collections.Generic; -using System.Data.Entity; -using System.Linq; -using System.Text; -using System.Threading.Tasks; -using Tango.BL; -using Tango.Telemetry.TelemetryObjects; - -namespace Tango.Telemetry.Modules -{ - public class TelemetryJobRunsHistoryModule : TelemetryConfigurableModule<TelemetryJobRunsHistoryModuleConfig>, ITelemetryHistoryModule - { - private bool _isBusy; - - public string Name { get; private set; } = "JobRuns History"; - - public Task<bool> CanRequestHistory(DateTime from) - { - return Task.FromResult(!_isBusy); - } - - public async Task<IEnumerable<ITelemetry>> RequestHistory(DateTime from) - { - try - { - _isBusy = true; - - using (ObservablesContext db = ObservablesContext.CreateDefault()) - { - var runs = await db.JobRuns - .Where(x => x.LastUpdated > from) - .OrderBy(x => x.LastUpdated) - .Take(Config.MaxJobRunsPerRequest) - .ToListAsync(); - - List<TelemetryJobRun> tRuns = new List<TelemetryJobRun>(); - - foreach (var run in runs) - { - TelemetryJobRun tRun = new TelemetryJobRun(); - tRun.Time = run.LastUpdated; - //Fill the object.. - tRuns.Add(tRun); - } - - return tRuns; - } - } - finally - { - _isBusy = false; - } - } - - public void Dispose() - { - - } - } -} |
