diff --git a/src/Exceptions/JobListenerException.cs b/src/Exceptions/JobListenerException.cs index f9f4b2e..64e951b 100644 --- a/src/Exceptions/JobListenerException.cs +++ b/src/Exceptions/JobListenerException.cs @@ -5,7 +5,7 @@ namespace Arcane.Operator.Exceptions; /// /// Thrown when an error occurs in the job listener /// -public class JobListenerException: Exception +public class JobListenerException : Exception { /// /// Thrown when an error occurs in the job listener diff --git a/src/Services/Operators/StreamingJobOperatorService.cs b/src/Services/Operators/StreamingJobOperatorService.cs index 4d925fa..a0a0a18 100644 --- a/src/Services/Operators/StreamingJobOperatorService.cs +++ b/src/Services/Operators/StreamingJobOperatorService.cs @@ -163,7 +163,7 @@ private Task>> OnJobDelete(V1Job job) RemoveAnnotationCommand command => this.removeAnnotationHandler.Handle(command), _ => throw new ArgumentOutOfRangeException(nameof(response), response, null) }; - + private Directive HandleError(Exception exception) { this.logger.LogError(exception, "Failed to handle stream definition event"); @@ -173,13 +173,13 @@ private Directive HandleError(Exception exception) _ => this.LogAndStop(exception), }; } - + private Directive LogAndContinue(Exception exception) { this.logger.LogWarning(exception, "Failed to handle stream definition event"); return Directive.Resume; } - + private Directive LogAndStop(Exception exception) { this.logger.LogError(exception, "Failed to handle stream definition event");