diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml index 4b42778f..ea7d1334 100644 --- a/.github/workflows/build.yml +++ b/.github/workflows/build.yml @@ -6,6 +6,14 @@ on: description: "The branch to use to build a SNAPSHOT from." required: true default: "main" + skip-tests: + type: choice + description: Whether to skip tests? + required: false + options: + - "true" + - "false" + default: "false" jobs: deploy: name: Build SNAPSHOT to Sonatype @@ -33,7 +41,7 @@ jobs: settings-path: ${{ github.workspace }} - name: Run Maven Targets - run: mvn deploy jacoco:report checkstyle:checkstyle spotbugs:spotbugs --settings $GITHUB_WORKSPACE/settings.xml --batch-mode --show-version --no-transfer-progress --activate-profiles sonatype-oss-release-github-actions + run: mvn deploy -DskipTests=${{ github.event.inputs.skip-tests }} jacoco:report checkstyle:checkstyle spotbugs:spotbugs --settings $GITHUB_WORKSPACE/settings.xml --batch-mode --show-version --no-transfer-progress --activate-profiles sonatype-oss-release-github-actions env: SONATYPE_USERNAME: ${{ secrets.SONATYPE_USERNAME }} SONATYPE_PASSWORD: ${{ secrets.SONATYPE_PASSWORD }} diff --git a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGenerator.java b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGenerator.java index 159dc0d8..177867cb 100644 --- a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGenerator.java +++ b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/ExpiredHousekeepingMetadataGenerator.java @@ -72,6 +72,9 @@ public ExpiredHousekeepingMetadataGenerator(String cleanupDelay) { @Override public List generate(ListenerEvent listenerEvent, String clientId) { List housekeepingEntities = new ArrayList<>(); + log + .info("Processing '{}' event for table: {}.{}", listenerEvent.getEventType(), listenerEvent.getDbName(), + listenerEvent.getTableName()); switch (listenerEvent.getEventType()) { case CREATE_TABLE: diff --git a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/UnreferencedHousekeepingPathGenerator.java b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/UnreferencedHousekeepingPathGenerator.java index 4ebb0ff9..cde7bc9e 100644 --- a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/UnreferencedHousekeepingPathGenerator.java +++ b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/generator/UnreferencedHousekeepingPathGenerator.java @@ -69,6 +69,9 @@ public UnreferencedHousekeepingPathGenerator(String cleanupDelay) { @Override public List generate(ListenerEvent listenerEvent, String clientId) { List housekeepingEntities = new ArrayList<>(); + log + .info("Processing '{}' event for table: {}.{}", listenerEvent.getEventType(), listenerEvent.getDbName(), + listenerEvent.getTableName()); switch (listenerEvent.getEventType()) { case ALTER_PARTITION: diff --git a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/handler/MessageEventHandler.java b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/handler/MessageEventHandler.java index d07912b2..21ef29bc 100644 --- a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/handler/MessageEventHandler.java +++ b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/handler/MessageEventHandler.java @@ -1,5 +1,5 @@ /** - * Copyright (C) 2019-2023 Expedia, Inc. + * Copyright (C) 2019-2024 Expedia, Inc. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. @@ -45,9 +45,12 @@ public MessageEventHandler(HousekeepingEntityGenerator generator, List handleMessage(MessageEvent event) { ListenerEvent listenerEvent = event.getEvent(); + log.info("Filtering message {}, generator {}", filters, generator.getClass().getSimpleName()); if (shouldFilterMessage(listenerEvent)) { + log.info("Filtered message {}", event); return Collections.emptyList(); } + log.info("Filtered message"); return generateHousekeepingEntities(listenerEvent); } diff --git a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/messaging/MessageReaderAdapter.java b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/messaging/MessageReaderAdapter.java index 04eff5ce..237c778c 100644 --- a/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/messaging/MessageReaderAdapter.java +++ b/beekeeper-scheduler-apiary/src/main/java/com/expediagroup/beekeeper/scheduler/apiary/messaging/MessageReaderAdapter.java @@ -54,7 +54,7 @@ public Optional read() { } MessageEvent message = messageEvent.get(); - + log.info("Received message: {}", message); List housekeepingEntities = handlers.parallelStream() .map(eventHandler -> eventHandler.handleMessage(message)) .flatMap(Collection::stream)