diff --git a/server/ee/libs/platform/platform-scheduler/platform-scheduler-aws/src/main/java/com/bytechef/ee/platform/scheduler/aws/AwsConnectionRefreshScheduler.java b/server/ee/libs/platform/platform-scheduler/platform-scheduler-aws/src/main/java/com/bytechef/ee/platform/scheduler/aws/AwsConnectionRefreshScheduler.java index fa8780e8ec4..3e09942740c 100644 --- a/server/ee/libs/platform/platform-scheduler/platform-scheduler-aws/src/main/java/com/bytechef/ee/platform/scheduler/aws/AwsConnectionRefreshScheduler.java +++ b/server/ee/libs/platform/platform-scheduler/platform-scheduler-aws/src/main/java/com/bytechef/ee/platform/scheduler/aws/AwsConnectionRefreshScheduler.java @@ -52,6 +52,8 @@ public void cancelConnectionRefresh(Long connectionId, String tenantId) { schedulerClient.deleteSchedule(request -> request.clientToken(tenantId + connectionId) .groupName(CONNECTION_REFRESH) .name(CONNECTION_REFRESH + tenantId + connectionId)); + + log.info("Canceling connection refresh for connection: {}, tenant: {}", connectionId, tenantId); } catch (RuntimeException e) { if (log.isDebugEnabled()) { log.debug("Dynamic Webhook Trigger Refresh not defined"); diff --git a/server/libs/platform/platform-connection/platform-connection-service/src/main/java/com/bytechef/platform/connection/facade/ConnectionFacadeImpl.java b/server/libs/platform/platform-connection/platform-connection-service/src/main/java/com/bytechef/platform/connection/facade/ConnectionFacadeImpl.java index 6c472fbdb5d..cf42be3b775 100644 --- a/server/libs/platform/platform-connection/platform-connection-service/src/main/java/com/bytechef/platform/connection/facade/ConnectionFacadeImpl.java +++ b/server/libs/platform/platform-connection/platform-connection-service/src/main/java/com/bytechef/platform/connection/facade/ConnectionFacadeImpl.java @@ -161,6 +161,8 @@ public Long executeConnectionRefresh(Long connectionId) { Map parameters = connection.getParameters(); + logger.info("Scheduled refresh of connection parameters for connection with connectionId: {}", connectionId); + return (Long) parameters.get("expires_in"); }