feat: set the SGStream as completed when running with a Deployment

Author: teoincontatto

stackgres-k8s/src/stream/src/main/java/io/stackgres/stream/jobs/StreamLauncher.java

@@ -153,6 +153,7 @@ public void launchStream(String streamName, String namespace) {
               .invoke(() -> {
                 LOGGER.info("Operation completed for SGStream {}", streamName);
                 if (Optional.ofNullable(stream.getSpec().getMaxRetries()).orElse(-1) < 0) {
+                  updateToCompletedConditions(streamName, namespace);
                   LOGGER.info("SGStream completed, waiting for user to delete the SGStream");
                   while (true) {
                     Unchecked.runnable(() -> Thread.sleep(1000)).run();
@@ -197,6 +198,10 @@ private void updateToTimeoutConditions(String streamName, String namespace) {
     updateToConditions(streamName, namespace, getTimeoutConditions());
   }
 
+  private void updateToCompletedConditions(String streamName, String namespace) {
+    updateToConditions(streamName, namespace, getCompletedConditions());
+  }
+
   public List<Condition> getStartingConditions() {
     final List<Condition> conditions = List.of(
         StreamStatusCondition.STREAM_RUNNING.getCondition(),
@@ -227,4 +232,14 @@ public List<Condition> getTimeoutConditions() {
     return conditions;
   }
 
+  public List<Condition> getCompletedConditions() {
+    final List<Condition> conditions = List.of(
+        StreamStatusCondition.STREAM_FALSE_RUNNING.getCondition(),
+        StreamStatusCondition.STREAM_COMPLETED.getCondition(),
+        StreamStatusCondition.STREAM_FALSE_FAILED.getCondition()
+    );
+    Condition.setTransitionTimes(conditions);
+    return conditions;
+  }
+
 }