diff options
| author | Roy Ben Shabat <Roy.mail.net@gmail.com> | 2025-08-02 21:38:19 +0300 |
|---|---|---|
| committer | Roy Ben Shabat <Roy.mail.net@gmail.com> | 2025-08-02 21:38:19 +0300 |
| commit | 0df9f37075dd697ac34f4ed2a2749f62aa27a654 (patch) | |
| tree | 5d95103b41d4954eff9f266317c5a525e9a0e3e9 /Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryJobRunsHistoryModule.cs | |
| parent | 4222eddece906d6f0877022c06b853deb5068472 (diff) | |
| download | Tango-0df9f37075dd697ac34f4ed2a2749f62aa27a654.tar.gz Tango-0df9f37075dd697ac34f4ed2a2749f62aa27a654.zip | |
Telemetry Testing.
Diffstat (limited to 'Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryJobRunsHistoryModule.cs')
| -rw-r--r-- | Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryJobRunsHistoryModule.cs | 61 |
1 files changed, 0 insertions, 61 deletions
diff --git a/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryJobRunsHistoryModule.cs b/Software/Visual_Studio/Tango.Telemetry/Sources/TelemetryJobRunsHistoryModule.cs deleted file mode 100644 index 6cb597e4b..000000000 --- a/Software/Visual_Studio/Tango.Telemetry/Sources/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.Telemetries; - -namespace Tango.Telemetry.Sources -{ - public class TelemetryJobRunsHistorySource : TelemetryConfigurableSource<TelemetryJobRunsHistorySourceConfig>, ITelemetryHistorySource - { - 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() - { - - } - } -} |
