Fix formatting issues

SneaksAndData · May 22, 2024 · 8104b4f · 8104b4f
1 parent e56a69d
commit 8104b4f
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git 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
@@ -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>(),