ci: fix tck tests

Author: ndr-brt

spi/data-plane/data-plane-spi/src/main/java/org/eclipse/edc/connector/dataplane/spi/iam/DataPlaneAuthorizationService.java

@@ -37,9 +37,6 @@ public interface DataPlaneAuthorizationService {
      * <p>
      * In addition, this service checks whether the token has permission to access the data identified by the {@code requestData} parameter, which could be a URL,
      * or query params, etc.
-     * <p>
-     * The result (if successful) of this method is the original {@link DataAddress} that was passed to a previous invocation of
-     * {@link DataPlaneAuthorizationService#createEndpointDataReference(DataFlow)}, i.e. {@link DataFlowStartMessage#getSourceDataAddress()}.
      *
      * @param token       The raw, encoded token, e.g. serialized JWT
      * @param requestData Additional information about the request, such as a URL, query params, headers, etc.

system-tests/protocol-tck/tck-extension/src/main/java/org/eclipse/edc/tck/dsp/guard/StatefulEntityTriggerSubscriber.java

@@ -56,7 +56,7 @@ public void register(Trigger<SE> trigger) {
     public <E extends Event> void on(EventEnvelope<E> envelope) {
 
         try {
-            TimeUnit.MILLISECONDS.sleep(100);
+            TimeUnit.MILLISECONDS.sleep(300);
         } catch (InterruptedException e) {
             throw new RuntimeException(e);
         }
@@ -67,9 +67,13 @@ public <E extends Event> void on(EventEnvelope<E> envelope) {
                         var event = baseEventPayload.cast(envelope.getPayload());
                         transactionContext.execute(() -> {
                             var id = idFromEventPayload.apply(event);
-                            var entity = store.findByIdAndLease(id).getContent();
-                            trigger.action().accept(entity);
-                            update(entity);
+                            store.findByIdAndLease(id)
+                                    .onSuccess(entity -> {
+                                        trigger.action().accept(entity);
+                                        update(entity);
+                                    }).onFailure(f -> {
+                                        monitor.warning("Cannot find entity %s: %s, so trigger doesn't get executed. Event: %s".formatted(id, f.getReason(), event.getClass().getSimpleName()));
+                                    });
                         });
                     } catch (Exception e) {
                         monitor.severe("Generic error while trying to execute TCK trigger on event " + envelope.getPayload().name(), e);