Skip to content

Commit

Permalink
Format the source code
Browse files Browse the repository at this point in the history
  • Loading branch information
s-vitaliy committed Oct 10, 2024
1 parent d2f6805 commit 6d9407a
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion src/Exceptions/JobListenerException.cs
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ namespace Arcane.Operator.Exceptions;
/// <summary>
/// Thrown when an error occurs in the job listener
/// </summary>
public class JobListenerException: Exception
public class JobListenerException : Exception
{
/// <summary>
/// Thrown when an error occurs in the job listener
Expand Down
6 changes: 3 additions & 3 deletions src/Services/Operators/StreamingJobOperatorService.cs
Original file line number Diff line number Diff line change
Expand Up @@ -163,7 +163,7 @@ private Task<List<Option<KubernetesCommand>>> OnJobDelete(V1Job job)
RemoveAnnotationCommand<IStreamDefinition> 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");
Expand All @@ -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");
Expand Down

0 comments on commit 6d9407a

Please sign in to comment.