Adding logger to WorkflowActivityContext

Signed-off-by: Artur Ciocanu <ciocanu@adobe.com>
This commit is contained in:
Artur Ciocanu 2025-08-30 14:58:23 -07:00
parent 5e0098a4c5
commit b5b5e9e78d
3 changed files with 34 additions and 0 deletions

View File

@ -13,8 +13,12 @@ limitations under the License.
package io.dapr.workflows;
import org.slf4j.Logger;
public interface WorkflowActivityContext {
Logger getLogger();
String getName();
String getTaskExecutionId();

View File

@ -15,12 +15,15 @@ package io.dapr.workflows.runtime;
import io.dapr.durabletask.TaskActivityContext;
import io.dapr.workflows.WorkflowActivityContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
* Wrapper for Durable Task Framework {@link TaskActivityContext}.
*/
class DefaultWorkflowActivityContext implements WorkflowActivityContext {
private final TaskActivityContext innerContext;
private final Logger logger;
/**
* Constructor for WorkflowActivityContext.
@ -29,10 +32,36 @@ class DefaultWorkflowActivityContext implements WorkflowActivityContext {
* @throws IllegalArgumentException if context is null
*/
public DefaultWorkflowActivityContext(TaskActivityContext context) throws IllegalArgumentException {
this(context, LoggerFactory.getLogger(WorkflowActivityContext .class));
}
/**
* Constructor for WorkflowActivityContext.
*
* @param context TaskActivityContext
* @throws IllegalArgumentException if context is null
*/
public DefaultWorkflowActivityContext(TaskActivityContext context, Logger logger) throws IllegalArgumentException {
if (context == null) {
throw new IllegalArgumentException("Context cannot be null");
}
if (logger == null) {
throw new IllegalArgumentException("Logger cannot be null");
}
this.innerContext = context;
this.logger = logger;
}
/**
* Gets the logger for the current activity.
*
* @return the logger for the current activity
*/
@Override
public Logger getLogger() {
return this.logger;
}
/**

View File

@ -63,6 +63,7 @@ public class DefaultWorkflowContext implements WorkflowContext {
if (context == null) {
throw new IllegalArgumentException("Context cannot be null");
}
if (logger == null) {
throw new IllegalArgumentException("Logger cannot be null");
}