From 8104b4fe3a3a0f4510175dca4adfdd2968e09f3d Mon Sep 17 00:00:00 2001
From: Vitalii Savitskii <visa@ecco.com>
Date: Wed, 22 May 2024 13:11:01 +0200
Subject: [PATCH] Fix formatting issues

---
 .../StreamingJobCommandHandler.cs                |  2 +-
 test/Services/StreamOperatorServiceTests.cs      | 16 ++++++++--------
 2 files changed, 9 insertions(+), 9 deletions(-)

diff --git a/src/Services/CommandHandlers/StreamingJobCommandHandler.cs b/src/Services/CommandHandlers/StreamingJobCommandHandler.cs
index f19cc1e..733f386 100644
--- a/src/Services/CommandHandlers/StreamingJobCommandHandler.cs
+++ b/src/Services/CommandHandlers/StreamingJobCommandHandler.cs
@@ -52,7 +52,7 @@ public Task Handle(SetAnnotationCommand<V1Job> command)
             .TryMap(job => job.AsOption(),
                 exception =>
                 {
-                    this.logger.LogError(exception, "Failed to annotate {streamId} with {annotationKey}:{annotationValue}", 
+                    this.logger.LogError(exception, "Failed to annotate {streamId} with {annotationKey}:{annotationValue}",
                         command.affectedResource, command.annotationKey, command.annotationValue);
                     return Option<V1Job>.None;
                 });
diff --git a/test/Services/StreamOperatorServiceTests.cs b/test/Services/StreamOperatorServiceTests.cs
index b635526..6a994e0 100644
--- a/test/Services/StreamOperatorServiceTests.cs
+++ b/test/Services/StreamOperatorServiceTests.cs
@@ -106,13 +106,13 @@ public async Task TestHandleAddedStreamEvent(WatchEventType eventType,
             It.IsAny<string>()))
             .Callback(() => this.tcs.SetResult());
 
-       this.kubeClusterMock 
-            .Setup(service => service.DeleteJob(
-                It.IsAny<string>(),
-                It.IsAny<string>(),
-                It.IsAny<CancellationToken>(),
-                It.IsAny<PropagationPolicy>()))
-            .Callback(() => this.tcs.SetResult());
+        this.kubeClusterMock
+             .Setup(service => service.DeleteJob(
+                 It.IsAny<string>(),
+                 It.IsAny<string>(),
+                 It.IsAny<CancellationToken>(),
+                 It.IsAny<PropagationPolicy>()))
+             .Callback(() => this.tcs.SetResult());
 
         // Act
         var sp = this.CreateServiceProvider();
@@ -125,7 +125,7 @@ public async Task TestHandleAddedStreamEvent(WatchEventType eventType,
                 => service.StartRegisteredStream(
                     It.IsAny<StreamDefinition>(), true, It.IsAny<IStreamClass>()),
             Times.Exactly(expectBackfill ? 1 : 0));
-        
+
         this.kubeClusterMock
             .Verify(c => c.AnnotateJob(It.IsAny<string>(),
             It.IsAny<string>(),