yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-08-26 01:46:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

MINOR - None schedules still need Ingestion Pipelines (#18425)

Browse Source
This commit is contained in:
Pere Miquel Brull 2024-10-28 12:44:21 +01:00
parent 3f1d8c7cd5
commit dbfe79feef
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
openmetadata-service/src/main/java/org/openmetadata/service/apps/AbstractNativeApplication.java
View File

@ -14,7 +14,6 @@ import org.openmetadata.schema.api.services.ingestionPipelines.CreateIngestionPi
import org.openmetadata.schema.entity.app.App; import org.openmetadata.schema.entity.app.App;
import org.openmetadata.schema.entity.app.AppRunRecord; import org.openmetadata.schema.entity.app.AppRunRecord;
import org.openmetadata.schema.entity.app.AppType; import org.openmetadata.schema.entity.app.AppType;
import org.openmetadata.schema.entity.app.ScheduleTimeline;
import org.openmetadata.schema.entity.app.ScheduleType; import org.openmetadata.schema.entity.app.ScheduleType;
import org.openmetadata.schema.entity.app.ScheduledExecutionContext; import org.openmetadata.schema.entity.app.ScheduledExecutionContext;
import org.openmetadata.schema.entity.applications.configuration.ApplicationConfig; import org.openmetadata.schema.entity.applications.configuration.ApplicationConfig;
@ -65,9 +64,7 @@ public class AbstractNativeApplication implements NativeApplication {
@Override @Override
public void install() { public void install() {
// If the app does not have any Schedule Return without scheduling // If the app does not have any Schedule Return without scheduling
if (Boolean.TRUE.equals(app.getDeleted()) if (Boolean.TRUE.equals(app.getDeleted()) || (app.getAppSchedule() == null)) {
|| (app.getAppSchedule() != null
&& app.getAppSchedule().getScheduleTimeline().equals(ScheduleTimeline.NONE))) {
return; return;
} }
if (app.getAppType().equals(AppType.Internal) if (app.getAppType().equals(AppType.Internal)