diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/alerts/gchat/GChatWebhookPublisher.java b/openmetadata-service/src/main/java/org/openmetadata/service/alerts/gchat/GChatWebhookPublisher.java index ef7f31d1b15..3f1cd9502c7 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/alerts/gchat/GChatWebhookPublisher.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/alerts/gchat/GChatWebhookPublisher.java @@ -62,7 +62,7 @@ public class GChatWebhookPublisher extends AlertsActionPublisher { if (response.getStatus() >= 300 && response.getStatus() < 400) { // 3xx response/redirection is not allowed for callback. Set the webhook state as in error setErrorStatus(attemptTime, response.getStatus(), response.getStatusInfo().getReasonPhrase()); - } else if (response.getStatus() >= 300 && response.getStatus() < 600) { + } else if (response.getStatus() >= 400 && response.getStatus() < 600) { // 4xx, 5xx response retry delivering events after timeout setNextBackOff(); setAwaitingRetry(attemptTime, response.getStatus(), response.getStatusInfo().getReasonPhrase()); diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/alerts/generic/GenericWebhookPublisher.java b/openmetadata-service/src/main/java/org/openmetadata/service/alerts/generic/GenericWebhookPublisher.java index 89c36810848..2b8c6478009 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/alerts/generic/GenericWebhookPublisher.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/alerts/generic/GenericWebhookPublisher.java @@ -76,7 +76,7 @@ public class GenericWebhookPublisher extends AlertsActionPublisher { if (response.getStatus() >= 300 && response.getStatus() < 400) { // 3xx response/redirection is not allowed for callback. Set the webhook state as in error setErrorStatus(attemptTime, response.getStatus(), response.getStatusInfo().getReasonPhrase()); - } else if (response.getStatus() >= 300 && response.getStatus() < 600) { + } else if (response.getStatus() >= 400 && response.getStatus() < 600) { // 4xx, 5xx response retry delivering events after timeout setNextBackOff(); setAwaitingRetry(attemptTime, response.getStatus(), response.getStatusInfo().getReasonPhrase()); diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/alerts/msteams/MSTeamsWebhookPublisher.java b/openmetadata-service/src/main/java/org/openmetadata/service/alerts/msteams/MSTeamsWebhookPublisher.java index 4b26184fe90..cd7090983ca 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/alerts/msteams/MSTeamsWebhookPublisher.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/alerts/msteams/MSTeamsWebhookPublisher.java @@ -60,7 +60,7 @@ public class MSTeamsWebhookPublisher extends AlertsActionPublisher { if (response.getStatus() >= 300 && response.getStatus() < 400) { // 3xx response/redirection is not allowed for callback. Set the webhook state as in error setErrorStatus(attemptTime, response.getStatus(), response.getStatusInfo().getReasonPhrase()); - } else if (response.getStatus() >= 300 && response.getStatus() < 600) { + } else if (response.getStatus() >= 400 && response.getStatus() < 600) { // 4xx, 5xx response retry delivering events after timeout setNextBackOff(); setAwaitingRetry(attemptTime, response.getStatus(), response.getStatusInfo().getReasonPhrase()); diff --git a/openmetadata-service/src/main/java/org/openmetadata/service/alerts/slack/SlackWebhookEventPublisher.java b/openmetadata-service/src/main/java/org/openmetadata/service/alerts/slack/SlackWebhookEventPublisher.java index e44833dd77b..d61da44c586 100644 --- a/openmetadata-service/src/main/java/org/openmetadata/service/alerts/slack/SlackWebhookEventPublisher.java +++ b/openmetadata-service/src/main/java/org/openmetadata/service/alerts/slack/SlackWebhookEventPublisher.java @@ -61,7 +61,7 @@ public class SlackWebhookEventPublisher extends AlertsActionPublisher { if (response.getStatus() >= 300 && response.getStatus() < 400) { // 3xx response/redirection is not allowed for callback. Set the webhook state as in error setErrorStatus(attemptTime, response.getStatus(), response.getStatusInfo().getReasonPhrase()); - } else if (response.getStatus() >= 300 && response.getStatus() < 600) { + } else if (response.getStatus() >= 400 && response.getStatus() < 600) { // 4xx, 5xx response retry delivering events after timeout setNextBackOff(); setAwaitingRetry(attemptTime, response.getStatus(), response.getStatusInfo().getReasonPhrase());