Skip to content

Commit 8d0ef55

Browse files
committed
797 Wrap JobLauncher.run in TenantUtils.callWithTenantId for default tenant context.
1 parent 7d8d71d commit 8d0ef55

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

server/libs/modules/components/data-stream/src/main/java/com/bytechef/component/datastream/action/definition/DataStreamStreamActionDefinition.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,8 @@
4747
import java.util.Objects;
4848
import java.util.Optional;
4949
import java.util.stream.Collectors;
50+
51+
import com.bytechef.tenant.util.TenantUtils;
5052
import org.springframework.batch.core.Job;
5153
import org.springframework.batch.core.JobExecution;
5254
import org.springframework.batch.core.JobParameter;
@@ -143,7 +145,8 @@ protected Object perform(
143145
}
144146
});
145147

146-
JobExecution jobExecution = jobLauncher.run(job, jobParameters);
148+
JobExecution jobExecution = TenantUtils.callWithTenantId(
149+
TenantContext.DEFAULT_TENANT_ID, () -> jobLauncher.run(job, jobParameters));
147150

148151
List<Throwable> failureExceptions = jobExecution.getAllFailureExceptions();
149152

0 commit comments

Comments
 (0)