mirror of
https://github.com/kestra-io/kestra.git
synced 2025-12-25 11:12:12 -05:00
Compare commits
84 Commits
fix/remove
...
v0.17.13
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
57bc235db6 | ||
|
|
2f416daac0 | ||
|
|
97779f3bc4 | ||
|
|
54c4f1d702 | ||
|
|
f2cc5c0da6 | ||
|
|
c2fc728414 | ||
|
|
90492354e2 | ||
|
|
856a5f5a73 | ||
|
|
f09fa74129 | ||
|
|
936e4019b6 | ||
|
|
4c44090462 | ||
|
|
9feac234f6 | ||
|
|
935212344c | ||
|
|
5d4c4dc214 | ||
|
|
a152354bcd | ||
|
|
08455bbdf0 | ||
|
|
64e9d8d43f | ||
|
|
dd1b435720 | ||
|
|
9fca8c9148 | ||
|
|
09d6e0f092 | ||
|
|
c3abfe08ad | ||
|
|
f2d5df082d | ||
|
|
16c15116fe | ||
|
|
f9f8d93ad7 | ||
|
|
c3b1ceb289 | ||
|
|
f9f33b96c8 | ||
|
|
658f847c48 | ||
|
|
dcec04e20e | ||
|
|
b38ec8a21b | ||
|
|
35d801cbc2 | ||
|
|
511a10a65c | ||
|
|
c5daebe4aa | ||
|
|
bb800948e5 | ||
|
|
65f921d456 | ||
|
|
ded21b0902 | ||
|
|
7b109baac2 | ||
|
|
c11fe3466f | ||
|
|
94c5b7a6e4 | ||
|
|
99ab5be8b9 | ||
|
|
aaa3a0ace0 | ||
|
|
acc5a24d9a | ||
|
|
892bb114ca | ||
|
|
30e4fe4e0b | ||
|
|
fcada08edd | ||
|
|
a2df125a62 | ||
|
|
9d9c5dc1d1 | ||
|
|
dbb1a8eaa5 | ||
|
|
1db6b57091 | ||
|
|
934ea201a5 | ||
|
|
5dcd5b5af8 | ||
|
|
000124f3dd | ||
|
|
c37f104446 | ||
|
|
3cfa48987f | ||
|
|
79c22ee22c | ||
|
|
d3a2fa13a5 | ||
|
|
20078f1e19 | ||
|
|
72b86d9edf | ||
|
|
59634133bc | ||
|
|
1e34a5528b | ||
|
|
4aa3bd3ef2 | ||
|
|
f6581de304 | ||
|
|
fd225d87b4 | ||
|
|
9bb3f576ee | ||
|
|
30cdb373cc | ||
|
|
59c7d6a567 | ||
|
|
9e4e5f891e | ||
|
|
ea3ba991d1 | ||
|
|
1024c77289 | ||
|
|
36b29d6065 | ||
|
|
1c8177e185 | ||
|
|
3dd5d6bb71 | ||
|
|
16a641693a | ||
|
|
efdb075155 | ||
|
|
a99d52a406 | ||
|
|
852edea36e | ||
|
|
defa426259 | ||
|
|
3aadcfd683 | ||
|
|
0f5d59103a | ||
|
|
50b9120434 | ||
|
|
896c761502 | ||
|
|
381d1b381f | ||
|
|
72a428a439 | ||
|
|
7447e61dbc | ||
|
|
45ffc3cc22 |
29
.github/workflows/docker.yml
vendored
29
.github/workflows/docker.yml
vendored
@@ -7,14 +7,7 @@ on:
|
||||
description: 'Retag latest Docker images'
|
||||
required: true
|
||||
type: string
|
||||
options:
|
||||
- "true"
|
||||
- "false"
|
||||
skip-test:
|
||||
description: 'Skip test'
|
||||
required: false
|
||||
type: string
|
||||
default: "false"
|
||||
default: "true"
|
||||
options:
|
||||
- "true"
|
||||
- "false"
|
||||
@@ -125,6 +118,16 @@ jobs:
|
||||
packages: python3 python3-venv python-is-python3 python3-pip nodejs npm curl zip unzip
|
||||
python-libs: kestra
|
||||
steps:
|
||||
- uses: actions/checkout@v4
|
||||
|
||||
# Vars
|
||||
- name: Set image name
|
||||
id: vars
|
||||
run: |
|
||||
TAG=${GITHUB_REF#refs/*/}
|
||||
echo "tag=${TAG}" >> $GITHUB_OUTPUT
|
||||
echo "plugins=${{ matrix.image.plugins }}" >> $GITHUB_OUTPUT
|
||||
|
||||
# Download release
|
||||
- name: Download release
|
||||
uses: robinraju/release-downloader@v1.10
|
||||
@@ -137,14 +140,6 @@ jobs:
|
||||
run: |
|
||||
cp build/executable/* docker/app/kestra && chmod +x docker/app/kestra
|
||||
|
||||
# Vars
|
||||
- name: Set image name
|
||||
id: vars
|
||||
run: |
|
||||
TAG=${GITHUB_REF#refs/*/}
|
||||
echo "tag=${TAG}" >> $GITHUB_OUTPUT
|
||||
echo "plugins=${{ matrix.image.plugins }}" >> $GITHUB_OUTPUT
|
||||
|
||||
# Docker setup
|
||||
- name: Set up QEMU
|
||||
uses: docker/setup-qemu-action@v3
|
||||
@@ -179,7 +174,7 @@ jobs:
|
||||
- name: Retag to latest
|
||||
if: github.event.inputs.retag-latest == 'true'
|
||||
run: |
|
||||
regctl image copy ${{ format('kestra/kestra:{0}{1}', steps.vars.outputs.tag, matrix.image.name) }} ${{ format('kestra/kestra:latest{1}', matrix.image.name) }}
|
||||
regctl image copy ${{ format('kestra/kestra:{0}{1}', steps.vars.outputs.tag, matrix.image.name) }} ${{ format('kestra/kestra:latest{0}', matrix.image.name) }}
|
||||
|
||||
end:
|
||||
runs-on: ubuntu-latest
|
||||
|
||||
@@ -454,7 +454,7 @@ subprojects {
|
||||
}
|
||||
|
||||
maven.pom {
|
||||
description 'The modern, scalable orchestrator & scheduler open source platform'
|
||||
description = 'The modern, scalable orchestrator & scheduler open source platform'
|
||||
|
||||
developers {
|
||||
developer {
|
||||
|
||||
@@ -37,6 +37,12 @@ public class ExecutorCommand extends AbstractServerCommand {
|
||||
@CommandLine.Option(names = {"--skip-flows"}, split=",", description = "a list of flow identifiers (tenant|namespace|flowId) to skip, separated by a coma; for troubleshooting purpose only")
|
||||
private List<String> skipFlows = Collections.emptyList();
|
||||
|
||||
@CommandLine.Option(names = {"--skip-namespaces"}, split=",", description = "a list of namespace identifiers (tenant|namespace) to skip, separated by a coma; for troubleshooting purpose only")
|
||||
private List<String> skipNamespaces = Collections.emptyList();
|
||||
|
||||
@CommandLine.Option(names = {"--skip-tenants"}, split=",", description = "a list of tenants to skip, separated by a coma; for troubleshooting purpose only")
|
||||
private List<String> skipTenants = Collections.emptyList();
|
||||
|
||||
@CommandLine.Option(names = {"--start-executors"}, split=",", description = "a list of Kafka Stream executors to start, separated by a command. Use it only with the Kafka queue, for debugging purpose.")
|
||||
private List<String> startExecutors = Collections.emptyList();
|
||||
|
||||
@@ -54,6 +60,8 @@ public class ExecutorCommand extends AbstractServerCommand {
|
||||
public Integer call() throws Exception {
|
||||
this.skipExecutionService.setSkipExecutions(skipExecutions);
|
||||
this.skipExecutionService.setSkipFlows(skipFlows);
|
||||
this.skipExecutionService.setSkipNamespaces(skipNamespaces);
|
||||
this.skipExecutionService.setSkipTenants(skipTenants);
|
||||
|
||||
this.startExecutorService.applyOptions(startExecutors, notStartExecutors);
|
||||
|
||||
|
||||
@@ -32,7 +32,7 @@ public class LocalCommand extends StandAloneCommand {
|
||||
"kestra.queue.type", "h2",
|
||||
"kestra.storage.type", "local",
|
||||
"kestra.storage.local.base-path", data.toString(),
|
||||
"datasources.h2.url", "jdbc:h2:file:" + data.resolve("database") + ";DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE;LOCK_TIMEOUT=30000",
|
||||
"datasources.h2.url", "jdbc:h2:file:" + data.resolve("database") + ";TIME ZONE=UTC;DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE;LOCK_TIMEOUT=30000",
|
||||
"datasources.h2.username", "sa",
|
||||
"datasources.h2.password", "",
|
||||
"datasources.h2.driverClassName", "org.h2.Driver",
|
||||
|
||||
@@ -49,6 +49,12 @@ public class StandAloneCommand extends AbstractServerCommand {
|
||||
@CommandLine.Option(names = {"--skip-flows"}, split=",", description = "a list of flow identifiers (namespace.flowId) to skip, separated by a coma; for troubleshooting purpose only")
|
||||
private List<String> skipFlows = Collections.emptyList();
|
||||
|
||||
@CommandLine.Option(names = {"--skip-namespaces"}, split=",", description = "a list of namespace identifiers (tenant|namespace) to skip, separated by a coma; for troubleshooting purpose only")
|
||||
private List<String> skipNamespaces = Collections.emptyList();
|
||||
|
||||
@CommandLine.Option(names = {"--skip-tenants"}, split=",", description = "a list of tenants to skip, separated by a coma; for troubleshooting purpose only")
|
||||
private List<String> skipTenants = Collections.emptyList();
|
||||
|
||||
@CommandLine.Option(names = {"--no-tutorials"}, description = "Flag to disable auto-loading of tutorial flows.")
|
||||
boolean tutorialsDisabled = false;
|
||||
|
||||
@@ -74,6 +80,8 @@ public class StandAloneCommand extends AbstractServerCommand {
|
||||
public Integer call() throws Exception {
|
||||
this.skipExecutionService.setSkipExecutions(skipExecutions);
|
||||
this.skipExecutionService.setSkipFlows(skipFlows);
|
||||
this.skipExecutionService.setSkipNamespaces(skipNamespaces);
|
||||
this.skipExecutionService.setSkipTenants(skipTenants);
|
||||
|
||||
this.startExecutorService.applyOptions(startExecutors, notStartExecutors);
|
||||
|
||||
|
||||
@@ -23,10 +23,12 @@ import org.apache.commons.lang3.ArrayUtils;
|
||||
@Singleton
|
||||
@Slf4j
|
||||
public class MetricRegistry {
|
||||
public final static String METRIC_WORKER_JOB_PENDING_COUNT = "worker.job.pending";
|
||||
public final static String METRIC_WORKER_JOB_RUNNING_COUNT = "worker.job.running";
|
||||
public final static String METRIC_WORKER_JOB_THREAD_COUNT = "worker.job.thread";
|
||||
public final static String METRIC_WORKER_RUNNING_COUNT = "worker.running.count";
|
||||
public final static String METRIC_WORKER_QUEUED_DURATION = "worker.queued.duration";
|
||||
public final static String METRIC_WORKER_STARTED_COUNT = "worker.started.count";
|
||||
public final static String METRIC_WORKER_RETRYED_COUNT = "worker.retryed.count";
|
||||
public final static String METRIC_WORKER_TIMEOUT_COUNT = "worker.timeout.count";
|
||||
public final static String METRIC_WORKER_ENDED_COUNT = "worker.ended.count";
|
||||
public final static String METRIC_WORKER_ENDED_DURATION = "worker.ended.duration";
|
||||
@@ -143,7 +145,7 @@ public class MetricRegistry {
|
||||
*
|
||||
* @param workerTask the current WorkerTask
|
||||
* @param workerGroup the worker group, optional
|
||||
* @return tags to applied to metrics
|
||||
* @return tags to apply to metrics
|
||||
*/
|
||||
public String[] tags(WorkerTask workerTask, String workerGroup, String... tags) {
|
||||
var baseTags = ArrayUtils.addAll(
|
||||
@@ -164,7 +166,7 @@ public class MetricRegistry {
|
||||
*
|
||||
* @param workerTrigger the current WorkerTask
|
||||
* @param workerGroup the worker group, optional
|
||||
* @return tags to applied to metrics
|
||||
* @return tags to apply to metrics
|
||||
*/
|
||||
public String[] tags(WorkerTrigger workerTrigger, String workerGroup, String... tags) {
|
||||
var baseTags = ArrayUtils.addAll(
|
||||
@@ -184,7 +186,7 @@ public class MetricRegistry {
|
||||
* Return tags for current {@link WorkerTaskResult}
|
||||
*
|
||||
* @param workerTaskResult the current WorkerTaskResult
|
||||
* @return tags to applied to metrics
|
||||
* @return tags to apply to metrics
|
||||
*/
|
||||
public String[] tags(WorkerTaskResult workerTaskResult, String... tags) {
|
||||
var baseTags = ArrayUtils.addAll(
|
||||
@@ -200,7 +202,7 @@ public class MetricRegistry {
|
||||
* Return tags for current {@link WorkerTaskResult}
|
||||
*
|
||||
* @param subflowExecutionResult the current WorkerTaskResult
|
||||
* @return tags to applied to metrics
|
||||
* @return tags to apply to metrics
|
||||
*/
|
||||
public String[] tags(SubflowExecutionResult subflowExecutionResult, String... tags) {
|
||||
var baseTags = ArrayUtils.addAll(
|
||||
@@ -216,7 +218,7 @@ public class MetricRegistry {
|
||||
* Return tags for current {@link Task}
|
||||
*
|
||||
* @param task the current Task
|
||||
* @return tags to applied to metrics
|
||||
* @return tags to apply to metrics
|
||||
*/
|
||||
public String[] tags(Task task) {
|
||||
return new String[]{
|
||||
@@ -240,7 +242,7 @@ public class MetricRegistry {
|
||||
* Return tags for current {@link Execution}
|
||||
*
|
||||
* @param execution the current Execution
|
||||
* @return tags to applied to metrics
|
||||
* @return tags to apply to metrics
|
||||
*/
|
||||
public String[] tags(Execution execution) {
|
||||
var baseTags = new String[]{
|
||||
@@ -255,33 +257,21 @@ public class MetricRegistry {
|
||||
* Return tags for current {@link TriggerContext}
|
||||
*
|
||||
* @param triggerContext the current TriggerContext
|
||||
* @param workerGroup the worker group, optional
|
||||
* @return tags to applied to metrics
|
||||
* @return tags to apply to metrics
|
||||
*/
|
||||
public String[] tags(TriggerContext triggerContext, String workerGroup) {
|
||||
public String[] tags(TriggerContext triggerContext) {
|
||||
var baseTags = new String[]{
|
||||
TAG_FLOW_ID, triggerContext.getFlowId(),
|
||||
TAG_NAMESPACE_ID, triggerContext.getNamespace()
|
||||
};
|
||||
baseTags = workerGroup == null ? baseTags : ArrayUtils.addAll(baseTags, TAG_WORKER_GROUP, workerGroup);
|
||||
return triggerContext.getTenantId() == null ? baseTags : ArrayUtils.addAll(baseTags, TAG_TENANT_ID, triggerContext.getTenantId());
|
||||
}
|
||||
|
||||
/**
|
||||
* Return tags for current {@link TriggerContext}
|
||||
*
|
||||
* @param triggerContext the current TriggerContext
|
||||
* @return tags to applied to metrics
|
||||
*/
|
||||
public String[] tags(TriggerContext triggerContext) {
|
||||
return tags(triggerContext, null);
|
||||
}
|
||||
|
||||
/**
|
||||
* Return tags for current {@link SchedulerExecutionWithTrigger}.
|
||||
*
|
||||
* @param schedulerExecutionWithTrigger the current SchedulerExecutionWithTrigger
|
||||
* @return tags to applied to metrics
|
||||
* @return tags to apply to metrics
|
||||
*/
|
||||
public String[] tags(SchedulerExecutionWithTrigger schedulerExecutionWithTrigger, String... tags) {
|
||||
return ArrayUtils.addAll(
|
||||
@@ -294,7 +284,7 @@ public class MetricRegistry {
|
||||
/**
|
||||
* Return globals tags
|
||||
*
|
||||
* @return tags to applied to metrics
|
||||
* @return tags to apply to metrics
|
||||
*/
|
||||
public Tags tags(String... tags) {
|
||||
return Tags.of(tags);
|
||||
|
||||
@@ -9,6 +9,22 @@ import lombok.NoArgsConstructor;
|
||||
import lombok.ToString;
|
||||
import lombok.experimental.SuperBuilder;
|
||||
|
||||
/**
|
||||
* The Kestra event for killing an execution. A {@link ExecutionKilled} can be in two states:
|
||||
* <p>
|
||||
* <pre>
|
||||
* - {@link State#REQUESTED}: The event was requested either by an Executor or by an external request.
|
||||
* - {@link State#EXECUTED}: The event was consumed and processed by the Executor.
|
||||
* </pre>
|
||||
*
|
||||
* A {@link ExecutionKilled} will always transit from {@link State#REQUESTED} to {@link State#EXECUTED}
|
||||
* regardless of whether the associated execution exist or not to ensure that Workers will be notified for the tasks
|
||||
* to be killed no matter what the circumstances.
|
||||
* <p>
|
||||
* IMPORTANT: A {@link ExecutionKilled} is considered to be a fire-and-forget event. As a result, we do not manage a
|
||||
* COMPLETED state, i.e., the Executor will never wait for Workers to process an executed {@link ExecutionKilled}
|
||||
* before considering an execution to be KILLED.
|
||||
*/
|
||||
@Getter
|
||||
@SuperBuilder
|
||||
@EqualsAndHashCode
|
||||
|
||||
@@ -8,22 +8,6 @@ import jakarta.validation.constraints.NotNull;
|
||||
import lombok.*;
|
||||
import lombok.experimental.SuperBuilder;
|
||||
|
||||
/**
|
||||
* The Kestra event for killing an execution. A {@link ExecutionKilledExecution} can be in two states:
|
||||
* <p>
|
||||
* <pre>
|
||||
* - {@link State#REQUESTED}: The event was requested either by an Executor or by an external request.
|
||||
* - {@link State#EXECUTED}: The event was consumed and processed by the Executor.
|
||||
* </pre>
|
||||
*
|
||||
* A {@link ExecutionKilledExecution} will always transit from {@link State#REQUESTED} to {@link State#EXECUTED}
|
||||
* regardless of whether the associated execution exist or not to ensure that Workers will be notified for the tasks
|
||||
* to be killed no matter what the circumstances.
|
||||
* <p>
|
||||
* IMPORTANT: A {@link ExecutionKilledExecution} is considered to be a fire-and-forget event. As a result, we do not manage a
|
||||
* COMPLETED state, i.e., the Executor will never wait for Workers to process an executed {@link ExecutionKilledExecution}
|
||||
* before considering an execution to be KILLED.
|
||||
*/
|
||||
@Getter
|
||||
@SuperBuilder
|
||||
@EqualsAndHashCode
|
||||
@@ -47,8 +31,9 @@ public class ExecutionKilledExecution extends ExecutionKilled implements TenantI
|
||||
Boolean isOnKillCascade;
|
||||
|
||||
public boolean isEqual(WorkerTask workerTask) {
|
||||
return (workerTask.getTaskRun().getTenantId() == null || (workerTask.getTaskRun().getTenantId() != null && workerTask.getTaskRun().getTenantId().equals(this.tenantId))) &&
|
||||
workerTask.getTaskRun().getExecutionId().equals(this.executionId);
|
||||
String taskTenantId = workerTask.getTaskRun().getTenantId();
|
||||
String taskExecutionId = workerTask.getTaskRun().getExecutionId();
|
||||
return (taskTenantId == null || taskTenantId.equals(this.tenantId)) && taskExecutionId.equals(this.executionId);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -24,7 +24,7 @@ public class EnumInput extends Input<String> {
|
||||
|
||||
@Override
|
||||
public void validate(String input) throws ConstraintViolationException {
|
||||
if (!values.contains(input)) {
|
||||
if (!values.contains(input) & this.getRequired()) {
|
||||
throw ManualConstraintViolation.toConstraintViolationException(
|
||||
"it must match the values `" + values + "`",
|
||||
this,
|
||||
|
||||
@@ -1,18 +1,21 @@
|
||||
package io.kestra.core.models.flows.input;
|
||||
|
||||
import io.kestra.core.models.flows.Input;
|
||||
import jakarta.validation.ConstraintViolationException;
|
||||
import lombok.Builder;
|
||||
import lombok.Getter;
|
||||
import lombok.NoArgsConstructor;
|
||||
import lombok.experimental.SuperBuilder;
|
||||
|
||||
import java.net.URI;
|
||||
|
||||
import jakarta.validation.ConstraintViolationException;
|
||||
|
||||
@SuperBuilder
|
||||
@Getter
|
||||
@NoArgsConstructor
|
||||
public class FileInput extends Input<URI> {
|
||||
@Builder.Default
|
||||
public String extension = ".upl";
|
||||
|
||||
@Override
|
||||
public void validate(URI input) throws ConstraintViolationException {
|
||||
// no validation yet
|
||||
|
||||
@@ -79,7 +79,7 @@ public class Trigger extends TriggerContext {
|
||||
}
|
||||
|
||||
public String flowUid() {
|
||||
return Flow.uid(this.getTenantId(), this.getNamespace(), this.getFlowId(), Optional.of(this.getFlowRevision()));
|
||||
return Flow.uidWithoutRevision(this.getTenantId(), this.getNamespace(), this.getFlowId());
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -90,7 +90,6 @@ public class Trigger extends TriggerContext {
|
||||
.tenantId(flow.getTenantId())
|
||||
.namespace(flow.getNamespace())
|
||||
.flowId(flow.getId())
|
||||
.flowRevision(flow.getRevision())
|
||||
.triggerId(abstractTrigger.getId())
|
||||
.stopAfter(abstractTrigger.getStopAfter())
|
||||
.build();
|
||||
@@ -137,7 +136,6 @@ public class Trigger extends TriggerContext {
|
||||
.tenantId(execution.getTenantId())
|
||||
.namespace(execution.getNamespace())
|
||||
.flowId(execution.getFlowId())
|
||||
.flowRevision(execution.getFlowRevision())
|
||||
.triggerId(execution.getTrigger().getId())
|
||||
.date(trigger.getDate())
|
||||
.nextExecutionDate(trigger.getNextExecutionDate())
|
||||
@@ -175,7 +173,6 @@ public class Trigger extends TriggerContext {
|
||||
.tenantId(flow.getTenantId())
|
||||
.namespace(flow.getNamespace())
|
||||
.flowId(flow.getId())
|
||||
.flowRevision(flow.getRevision())
|
||||
.triggerId(abstractTrigger.getId())
|
||||
.date(ZonedDateTime.now().truncatedTo(ChronoUnit.SECONDS))
|
||||
.nextExecutionDate(nextDate)
|
||||
@@ -225,7 +222,6 @@ public class Trigger extends TriggerContext {
|
||||
.tenantId(this.getTenantId())
|
||||
.namespace(this.getNamespace())
|
||||
.flowId(this.getFlowId())
|
||||
.flowRevision(this.getFlowRevision())
|
||||
.triggerId(this.getTriggerId())
|
||||
.date(this.getDate())
|
||||
.nextExecutionDate(nextExecutionDate)
|
||||
@@ -240,7 +236,6 @@ public class Trigger extends TriggerContext {
|
||||
.tenantId(this.getTenantId())
|
||||
.namespace(this.getNamespace())
|
||||
.flowId(this.getFlowId())
|
||||
.flowRevision(this.getFlowRevision())
|
||||
.triggerId(this.getTriggerId())
|
||||
.date(this.getDate())
|
||||
.nextExecutionDate(this.getNextExecutionDate())
|
||||
@@ -301,7 +296,6 @@ public class Trigger extends TriggerContext {
|
||||
.tenantId(triggerContext.getTenantId())
|
||||
.namespace(triggerContext.getNamespace())
|
||||
.flowId(triggerContext.getFlowId())
|
||||
.flowRevision(triggerContext.getFlowRevision())
|
||||
.triggerId(triggerContext.getTriggerId())
|
||||
.date(triggerContext.getDate())
|
||||
.backfill(triggerContext.getBackfill())
|
||||
|
||||
@@ -29,9 +29,6 @@ public class TriggerContext {
|
||||
@NotNull
|
||||
private String flowId;
|
||||
|
||||
@NotNull
|
||||
private Integer flowRevision;
|
||||
|
||||
@NotNull
|
||||
private String triggerId;
|
||||
|
||||
@@ -53,7 +50,6 @@ public class TriggerContext {
|
||||
this.tenantId = b.tenantId;
|
||||
this.namespace = b.namespace;
|
||||
this.flowId = b.flowId;
|
||||
this.flowRevision = b.flowRevision;
|
||||
this.triggerId = b.triggerId;
|
||||
this.date = b.date;
|
||||
this.nextExecutionDate = b.nextExecutionDate;
|
||||
|
||||
@@ -1,7 +1,5 @@
|
||||
package io.kestra.core.models.triggers;
|
||||
|
||||
import io.kestra.core.exceptions.IllegalVariableEvaluationException;
|
||||
import io.kestra.core.models.Label;
|
||||
import io.kestra.core.models.conditions.ConditionContext;
|
||||
import io.kestra.core.models.executions.Execution;
|
||||
import io.kestra.core.models.executions.ExecutionTrigger;
|
||||
@@ -22,7 +20,7 @@ public abstract class TriggerService {
|
||||
ExecutionTrigger executionTrigger = ExecutionTrigger.of(trigger, variables);
|
||||
RunContext runContext = conditionContext.getRunContext();
|
||||
|
||||
return generateExecution(runContext.getTriggerExecutionId(), trigger, context, executionTrigger);
|
||||
return generateExecution(runContext.getTriggerExecutionId(), trigger, context, executionTrigger, conditionContext.getFlow().getRevision());
|
||||
}
|
||||
|
||||
public static Execution generateExecution(
|
||||
@@ -34,30 +32,32 @@ public abstract class TriggerService {
|
||||
ExecutionTrigger executionTrigger = ExecutionTrigger.of(trigger, output);
|
||||
RunContext runContext = conditionContext.getRunContext();
|
||||
|
||||
return generateExecution(runContext.getTriggerExecutionId(), trigger, context, executionTrigger);
|
||||
return generateExecution(runContext.getTriggerExecutionId(), trigger, context, executionTrigger, conditionContext.getFlow().getRevision());
|
||||
}
|
||||
|
||||
public static Execution generateRealtimeExecution(
|
||||
AbstractTrigger trigger,
|
||||
ConditionContext conditionContext,
|
||||
TriggerContext context,
|
||||
Output output
|
||||
) {
|
||||
ExecutionTrigger executionTrigger = ExecutionTrigger.of(trigger, output);
|
||||
|
||||
return generateExecution(IdUtils.create(), trigger, context, executionTrigger);
|
||||
return generateExecution(IdUtils.create(), trigger, context, executionTrigger, conditionContext.getFlow().getRevision());
|
||||
}
|
||||
|
||||
private static Execution generateExecution(
|
||||
String id,
|
||||
AbstractTrigger trigger,
|
||||
TriggerContext context,
|
||||
ExecutionTrigger executionTrigger
|
||||
ExecutionTrigger executionTrigger,
|
||||
Integer flowRevision
|
||||
) {
|
||||
return Execution.builder()
|
||||
.id(id)
|
||||
.namespace(context.getNamespace())
|
||||
.flowId(context.getFlowId())
|
||||
.flowRevision(context.getFlowRevision())
|
||||
.flowRevision(flowRevision)
|
||||
.state(new State())
|
||||
.trigger(executionTrigger)
|
||||
.labels(trigger.getLabels() == null ? null : trigger.getLabels())
|
||||
|
||||
@@ -51,7 +51,7 @@ public interface ExecutionRepositoryInterface extends SaveRepositoryInterface<Ex
|
||||
@Nullable ChildFilter childFilter
|
||||
);
|
||||
|
||||
Flux<Execution> find(
|
||||
default Flux<Execution> find(
|
||||
@Nullable String query,
|
||||
@Nullable String tenantId,
|
||||
@Nullable String namespace,
|
||||
@@ -62,6 +62,22 @@ public interface ExecutionRepositoryInterface extends SaveRepositoryInterface<Ex
|
||||
@Nullable Map<String, String> labels,
|
||||
@Nullable String triggerExecutionId,
|
||||
@Nullable ChildFilter childFilter
|
||||
) {
|
||||
return find(query, tenantId, namespace, flowId, startDate, endDate, state, labels, triggerExecutionId, childFilter, false);
|
||||
}
|
||||
|
||||
Flux<Execution> find(
|
||||
@Nullable String query,
|
||||
@Nullable String tenantId,
|
||||
@Nullable String namespace,
|
||||
@Nullable String flowId,
|
||||
@Nullable ZonedDateTime startDate,
|
||||
@Nullable ZonedDateTime endDate,
|
||||
@Nullable List<State.Type> state,
|
||||
@Nullable Map<String, String> labels,
|
||||
@Nullable String triggerExecutionId,
|
||||
@Nullable ChildFilter childFilter,
|
||||
boolean allowDeleted
|
||||
);
|
||||
|
||||
ArrayListTotal<TaskRun> findTaskRun(
|
||||
|
||||
@@ -35,6 +35,11 @@ public class Executor {
|
||||
private ExecutionResumed executionResumed;
|
||||
private ExecutionResumed joinedExecutionResumed;
|
||||
|
||||
/**
|
||||
* The sequence id should be incremented each time the execution is persisted after mutation.
|
||||
*/
|
||||
private long seqId = 0L;
|
||||
|
||||
/**
|
||||
* List of {@link ExecutionKilled} to be propagated part of the execution.
|
||||
*/
|
||||
@@ -45,6 +50,12 @@ public class Executor {
|
||||
this.offset = offset;
|
||||
}
|
||||
|
||||
public Executor(Execution execution, Long offset, long seqId) {
|
||||
this.execution = execution;
|
||||
this.offset = offset;
|
||||
this.seqId = seqId;
|
||||
}
|
||||
|
||||
public Executor(WorkerTaskResult workerTaskResult) {
|
||||
this.joinedWorkerTaskResult = workerTaskResult;
|
||||
}
|
||||
@@ -148,7 +159,18 @@ public class Executor {
|
||||
public Executor serialize() {
|
||||
return new Executor(
|
||||
this.execution,
|
||||
this.offset
|
||||
this.offset,
|
||||
this.seqId
|
||||
);
|
||||
}
|
||||
|
||||
/**
|
||||
* Increments and returns the execution sequence id.
|
||||
*
|
||||
* @return the sequence id.
|
||||
*/
|
||||
public long incrementAndGetSeqId() {
|
||||
this.seqId++;
|
||||
return seqId;
|
||||
}
|
||||
}
|
||||
|
||||
@@ -2,6 +2,7 @@ package io.kestra.core.runners;
|
||||
|
||||
import io.kestra.core.exceptions.IllegalVariableEvaluationException;
|
||||
import io.kestra.core.models.tasks.runners.PluginUtilsService;
|
||||
import io.kestra.core.utils.IdUtils;
|
||||
import io.kestra.core.utils.ListUtils;
|
||||
import org.apache.commons.io.IOUtils;
|
||||
import org.slf4j.Logger;
|
||||
@@ -44,17 +45,16 @@ public abstract class FilesService {
|
||||
file.getParentFile().mkdirs();
|
||||
}
|
||||
|
||||
var fileContent = runContext.render(input, additionalVars);
|
||||
if (fileContent == null) {
|
||||
if (input == null) {
|
||||
file.createNewFile();
|
||||
} else {
|
||||
if (fileContent.startsWith("kestra://")) {
|
||||
try (var is = runContext.storage().getFile(URI.create(fileContent));
|
||||
if (input.startsWith("kestra://")) {
|
||||
try (var is = runContext.storage().getFile(URI.create(input));
|
||||
var out = new FileOutputStream(file)) {
|
||||
IOUtils.copyLarge(is, out);
|
||||
}
|
||||
} else {
|
||||
Files.write(file.toPath(), fileContent.getBytes());
|
||||
Files.write(file.toPath(), input.getBytes());
|
||||
}
|
||||
}
|
||||
}));
|
||||
@@ -85,10 +85,14 @@ public abstract class FilesService {
|
||||
.filter(path -> pathMatcher.matches(runContext.tempDir().relativize(path)))
|
||||
.map(throwFunction(path -> new AbstractMap.SimpleEntry<>(
|
||||
runContext.tempDir().relativize(path).toString(),
|
||||
runContext.storage().putFile(path.toFile())
|
||||
runContext.storage().putFile(path.toFile(), resolveUniqueNameForFile(path))
|
||||
)))
|
||||
.toList()
|
||||
.stream();
|
||||
}
|
||||
}
|
||||
|
||||
private static String resolveUniqueNameForFile(final Path path) {
|
||||
return IdUtils.from(path.toString()) + "-" + path.toFile().getName();
|
||||
}
|
||||
}
|
||||
|
||||
@@ -8,6 +8,7 @@ import io.kestra.core.models.flows.Flow;
|
||||
import io.kestra.core.models.flows.Input;
|
||||
import io.kestra.core.models.flows.Type;
|
||||
import io.kestra.core.models.flows.input.ArrayInput;
|
||||
import io.kestra.core.models.flows.input.FileInput;
|
||||
import io.kestra.core.models.tasks.common.EncryptedString;
|
||||
import io.kestra.core.serializers.JacksonMapper;
|
||||
import io.kestra.core.storages.StorageInterface;
|
||||
@@ -85,7 +86,9 @@ public class FlowInputOutput {
|
||||
.subscribeOn(Schedulers.boundedElastic())
|
||||
.map(throwFunction(input -> {
|
||||
if (input instanceof CompletedFileUpload fileUpload) {
|
||||
File tempFile = File.createTempFile(fileUpload.getFilename() + "_", ".upl");
|
||||
String fileExtension = inputs.stream().filter(flowInput -> flowInput instanceof FileInput && flowInput.getId().equals(fileUpload.getFilename())).map(flowInput -> ((FileInput) flowInput).getExtension()).findFirst().orElse(".upl");
|
||||
fileExtension = fileExtension.startsWith(".") ? fileExtension : "." + fileExtension;
|
||||
File tempFile = File.createTempFile(fileUpload.getFilename() + "_", fileExtension);
|
||||
try (var inputStream = fileUpload.getInputStream();
|
||||
var outputStream = new FileOutputStream(tempFile)) {
|
||||
long transferredBytes = inputStream.transferTo(outputStream);
|
||||
|
||||
@@ -14,6 +14,7 @@ import io.kestra.core.services.FlowListenersInterface;
|
||||
import java.io.IOException;
|
||||
import java.util.ArrayList;
|
||||
import java.util.List;
|
||||
import java.util.Objects;
|
||||
import java.util.Optional;
|
||||
import java.util.function.BiConsumer;
|
||||
import java.util.function.Consumer;
|
||||
@@ -98,13 +99,13 @@ public class FlowListeners implements FlowListenersInterface {
|
||||
private Optional<Flow> previous(Flow flow) {
|
||||
return flows
|
||||
.stream()
|
||||
.filter(r -> r.getNamespace().equals(flow.getNamespace()) && r.getId().equals(flow.getId()))
|
||||
.filter(r -> Objects.equals(r.getTenantId(), flow.getTenantId()) && r.getNamespace().equals(flow.getNamespace()) && r.getId().equals(flow.getId()))
|
||||
.findFirst();
|
||||
}
|
||||
|
||||
private boolean remove(Flow flow) {
|
||||
synchronized (this) {
|
||||
boolean remove = flows.removeIf(r -> r.getNamespace().equals(flow.getNamespace()) && r.getId().equals(flow.getId()));
|
||||
boolean remove = flows.removeIf(r -> Objects.equals(r.getTenantId(), flow.getTenantId()) && r.getNamespace().equals(flow.getNamespace()) && r.getId().equals(flow.getId()));
|
||||
if (!remove && flow.isDeleted()) {
|
||||
log.warn("Can't remove flow {}.{}", flow.getNamespace(), flow.getId());
|
||||
}
|
||||
|
||||
@@ -31,7 +31,7 @@ public class NamespaceFilesService {
|
||||
private StorageInterface storageInterface;
|
||||
|
||||
public List<URI> inject(RunContext runContext, String tenantId, String namespace, Path basePath, NamespaceFiles namespaceFiles) throws Exception {
|
||||
if (!namespaceFiles.getEnabled()) {
|
||||
if (!Boolean.TRUE.equals(namespaceFiles.getEnabled())) {
|
||||
return Collections.emptyList();
|
||||
}
|
||||
|
||||
|
||||
@@ -339,7 +339,7 @@ public class RunContext {
|
||||
if (execution.getTaskRunList() != null) {
|
||||
Map<String, Object> outputs = new HashMap<>(execution.outputs());
|
||||
if (decryptVariables) {
|
||||
decryptOutputs(outputs);
|
||||
outputs = decryptOutputs(outputs);
|
||||
}
|
||||
builder.put("outputs", outputs);
|
||||
}
|
||||
@@ -401,25 +401,37 @@ public class RunContext {
|
||||
));
|
||||
}
|
||||
|
||||
if (this.runContextLogger != null) {
|
||||
builder.put("addSecretConsumer", (Consumer<String>) s -> this.runContextLogger.usedSecret(s));
|
||||
}
|
||||
|
||||
return builder.build();
|
||||
}
|
||||
|
||||
private void decryptOutputs(Map<String, Object> outputs) {
|
||||
for (var entry: outputs.entrySet()) {
|
||||
private Map<String, Object> decryptOutputs(Map<String, Object> mapToDecrypt) {
|
||||
if (mapToDecrypt == null) {
|
||||
return null;
|
||||
}
|
||||
|
||||
Map<String, Object> decryptedMap = new HashMap<>();
|
||||
for (var entry: mapToDecrypt.entrySet()) {
|
||||
decryptedMap.put(entry.getKey(), entry.getValue());
|
||||
if (entry.getValue() instanceof Map map) {
|
||||
// if some outputs are of type EncryptedString we decode them and replace the object
|
||||
// if some value are of type EncryptedString we decode them and replace the object
|
||||
if (EncryptedString.TYPE.equalsIgnoreCase((String)map.get("type"))) {
|
||||
try {
|
||||
String decoded = decrypt((String) map.get("value"));
|
||||
outputs.put(entry.getKey(), decoded);
|
||||
decryptedMap.put(entry.getKey(), decoded);
|
||||
} catch (GeneralSecurityException e) {
|
||||
throw new RuntimeException(e);
|
||||
}
|
||||
} else {
|
||||
decryptOutputs((Map<String, Object>) map);
|
||||
decryptedMap.put(entry.getKey(), decryptOutputs((Map<String, Object>) map));
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
return decryptedMap;
|
||||
}
|
||||
|
||||
private Map<String, Object> variables(TaskRun taskRun) {
|
||||
@@ -502,6 +514,8 @@ public class RunContext {
|
||||
runContext.runContextLogger = this.runContextLogger;
|
||||
runContext.tempBasedPath = this.tempBasedPath;
|
||||
runContext.temporaryDirectory = this.temporaryDirectory;
|
||||
runContext.pluginConfiguration = this.pluginConfiguration;
|
||||
runContext.secretKey = this.secretKey;
|
||||
|
||||
return runContext;
|
||||
}
|
||||
@@ -583,6 +597,17 @@ public class RunContext {
|
||||
return newContext;
|
||||
}
|
||||
|
||||
public RunContext forWorkingDirectoryTask(final Task task) {
|
||||
Map<String, Object> decryptedVariables = new HashMap<>(this.variables);
|
||||
if (this.variables.get("outputs") != null) {
|
||||
decryptedVariables.put("outputs", decryptOutputs((Map<String, Object>) this.variables.get("outputs")));
|
||||
}
|
||||
|
||||
RunContext newRunContext = this.clone(decryptedVariables);
|
||||
newRunContext.initPluginConfiguration(applicationContext, task.getClass(), task.getType());
|
||||
return newRunContext;
|
||||
}
|
||||
|
||||
public RunContext forTaskRunner(TaskRunner taskRunner) {
|
||||
this.initPluginConfiguration(applicationContext, taskRunner.getClass(), taskRunner.getType());
|
||||
|
||||
|
||||
@@ -166,7 +166,7 @@ public class VariableRenderer {
|
||||
}
|
||||
|
||||
public Map<String, Object> render(Map<String, Object> in, Map<String, Object> variables, boolean recursive) throws IllegalVariableEvaluationException {
|
||||
Map<String, Object> map = new HashMap<>();
|
||||
Map<String, Object> map = new LinkedHashMap<>();
|
||||
|
||||
for (Map.Entry<String, Object> r : in.entrySet()) {
|
||||
String key = this.render(r.getKey(), variables);
|
||||
|
||||
@@ -34,6 +34,7 @@ import io.micronaut.context.annotation.Parameter;
|
||||
import io.micronaut.context.event.ApplicationEventPublisher;
|
||||
import io.micronaut.core.annotation.Introspected;
|
||||
import io.micronaut.core.annotation.Nullable;
|
||||
import jakarta.annotation.PostConstruct;
|
||||
import jakarta.annotation.PreDestroy;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Named;
|
||||
@@ -126,6 +127,9 @@ public class Worker implements Service, Runnable, AutoCloseable {
|
||||
|
||||
private final AtomicReference<ServiceState> state = new AtomicReference<>();
|
||||
|
||||
private final Integer numThreads;
|
||||
private final AtomicInteger pendingJobCount = new AtomicInteger(0);
|
||||
private final AtomicInteger runningJobCount = new AtomicInteger(0);
|
||||
/**
|
||||
* Creates a new {@link Worker} instance.
|
||||
*
|
||||
@@ -143,6 +147,7 @@ public class Worker implements Service, Runnable, AutoCloseable {
|
||||
ExecutorsUtils executorsUtils
|
||||
) {
|
||||
this.id = workerId;
|
||||
this.numThreads = numThreads;
|
||||
this.workerGroup = workerGroupService.resolveGroupFromKey(workerGroupKey);
|
||||
this.eventPublisher = eventPublisher;
|
||||
this.executorService = executorsUtils.maxCachedThreadPool(numThreads, "worker");
|
||||
@@ -168,6 +173,15 @@ public class Worker implements Service, Runnable, AutoCloseable {
|
||||
context.inject(this);
|
||||
}
|
||||
|
||||
@PostConstruct
|
||||
void initMetrics() {
|
||||
String[] tags = this.workerGroup == null ? new String[0] : new String[] { MetricRegistry.TAG_WORKER_GROUP, this.workerGroup };
|
||||
// create metrics to store thread count, pending jobs and running jobs, so we can have autoscaling easily
|
||||
this.metricRegistry.gauge(MetricRegistry.METRIC_WORKER_JOB_THREAD_COUNT, numThreads, tags);
|
||||
this.metricRegistry.gauge(MetricRegistry.METRIC_WORKER_JOB_PENDING_COUNT, pendingJobCount, tags);
|
||||
this.metricRegistry.gauge(MetricRegistry.METRIC_WORKER_JOB_RUNNING_COUNT, runningJobCount, tags);
|
||||
}
|
||||
|
||||
@Override
|
||||
public void run() {
|
||||
setState(ServiceState.RUNNING);
|
||||
@@ -208,19 +222,29 @@ public class Worker implements Service, Runnable, AutoCloseable {
|
||||
this.workerGroup,
|
||||
Worker.class,
|
||||
either -> {
|
||||
pendingJobCount.incrementAndGet();
|
||||
|
||||
executorService.execute(() -> {
|
||||
if (either.isRight()) {
|
||||
log.error("Unable to deserialize a worker job: {}", either.getRight().getMessage());
|
||||
handleDeserializationError(either.getRight());
|
||||
return;
|
||||
pendingJobCount.decrementAndGet();
|
||||
runningJobCount.incrementAndGet();
|
||||
|
||||
try {
|
||||
if (either.isRight()) {
|
||||
log.error("Unable to deserialize a worker job: {}", either.getRight().getMessage());
|
||||
handleDeserializationError(either.getRight());
|
||||
return;
|
||||
}
|
||||
|
||||
WorkerJob workerTask = either.getLeft();
|
||||
if (workerTask instanceof WorkerTask task) {
|
||||
handleTask(task);
|
||||
} else if (workerTask instanceof WorkerTrigger trigger) {
|
||||
handleTrigger(trigger);
|
||||
}
|
||||
} finally {
|
||||
runningJobCount.decrementAndGet();
|
||||
}
|
||||
|
||||
WorkerJob workerTask = either.getLeft();
|
||||
if (workerTask instanceof WorkerTask task) {
|
||||
handleTask(task);
|
||||
} else if (workerTask instanceof WorkerTrigger trigger) {
|
||||
handleTrigger(trigger);
|
||||
}
|
||||
});
|
||||
}
|
||||
);
|
||||
@@ -285,7 +309,7 @@ public class Worker implements Service, Runnable, AutoCloseable {
|
||||
WorkerTask currentWorkerTask = workingDirectory.workerTask(
|
||||
workerTask.getTaskRun(),
|
||||
currentTask,
|
||||
runContext
|
||||
runContext.forWorkingDirectoryTask(currentTask)
|
||||
);
|
||||
|
||||
// all tasks will be handled immediately by the worker
|
||||
@@ -378,13 +402,13 @@ public class Worker implements Service, Runnable, AutoCloseable {
|
||||
.increment();
|
||||
|
||||
this.metricRegistry
|
||||
.timer(MetricRegistry.METRIC_WORKER_TRIGGER_DURATION, metricRegistry.tags(workerTrigger.getTriggerContext(), workerGroup))
|
||||
.timer(MetricRegistry.METRIC_WORKER_TRIGGER_DURATION, metricRegistry.tags(workerTrigger, workerGroup))
|
||||
.record(() -> {
|
||||
StopWatch stopWatch = new StopWatch();
|
||||
stopWatch.start();
|
||||
|
||||
this.evaluateTriggerRunningCount.computeIfAbsent(workerTrigger.getTriggerContext().uid(), s -> metricRegistry
|
||||
.gauge(MetricRegistry.METRIC_WORKER_TRIGGER_RUNNING_COUNT, new AtomicInteger(0), metricRegistry.tags(workerTrigger.getTriggerContext(), workerGroup)));
|
||||
.gauge(MetricRegistry.METRIC_WORKER_TRIGGER_RUNNING_COUNT, new AtomicInteger(0), metricRegistry.tags(workerTrigger, workerGroup)));
|
||||
this.evaluateTriggerRunningCount.get(workerTrigger.getTriggerContext().uid()).addAndGet(1);
|
||||
|
||||
try {
|
||||
|
||||
@@ -178,7 +178,6 @@ public abstract class AbstractScheduler implements Scheduler, Service {
|
||||
if (abstractTrigger instanceof WorkerTriggerInterface) {
|
||||
RunContext runContext = runContextFactory.of(flow, abstractTrigger);
|
||||
ConditionContext conditionContext = conditionService.conditionContext(runContext, flow, null);
|
||||
Trigger trigger = Trigger.of(flow, abstractTrigger);
|
||||
|
||||
try {
|
||||
this.triggerState.update(flow, abstractTrigger, conditionContext);
|
||||
@@ -186,6 +185,7 @@ public abstract class AbstractScheduler implements Scheduler, Service {
|
||||
logError(conditionContext, flow, abstractTrigger, e);
|
||||
}
|
||||
|
||||
Trigger trigger = Trigger.of(flow, abstractTrigger);
|
||||
this.executionKilledQueue.emit(ExecutionKilledTrigger
|
||||
.builder()
|
||||
.tenantId(trigger.getTenantId())
|
||||
@@ -255,7 +255,6 @@ public abstract class AbstractScheduler implements Scheduler, Service {
|
||||
.tenantId(flowAndTrigger.flow().getTenantId())
|
||||
.namespace(flowAndTrigger.flow().getNamespace())
|
||||
.flowId(flowAndTrigger.flow().getId())
|
||||
.flowRevision(flowAndTrigger.flow().getRevision())
|
||||
.triggerId(flowAndTrigger.trigger().getId())
|
||||
.date(now())
|
||||
.nextExecutionDate(nextExecutionDate)
|
||||
@@ -368,7 +367,7 @@ public abstract class AbstractScheduler implements Scheduler, Service {
|
||||
public List<FlowWithTriggers> schedulerTriggers() {
|
||||
Map<String, Flow> flows = this.flowListeners.flows()
|
||||
.stream()
|
||||
.collect(Collectors.toMap(Flow::uid, Function.identity()));
|
||||
.collect(Collectors.toMap(Flow::uidWithoutRevision, Function.identity()));
|
||||
|
||||
return this.triggerState.findAllForAllTenants().stream()
|
||||
.filter(trigger -> flows.containsKey(trigger.flowUid()))
|
||||
@@ -526,7 +525,6 @@ public abstract class AbstractScheduler implements Scheduler, Service {
|
||||
.tenantId(f.getTriggerContext().getTenantId())
|
||||
.namespace(f.getTriggerContext().getNamespace())
|
||||
.flowId(f.getTriggerContext().getFlowId())
|
||||
.flowRevision(f.getTriggerContext().getFlowRevision())
|
||||
.labels(f.getFlow().getLabels())
|
||||
.state(new State().withState(State.Type.FAILED))
|
||||
.build();
|
||||
@@ -849,7 +847,6 @@ public abstract class AbstractScheduler implements Scheduler, Service {
|
||||
.tenantId(f.getTriggerContext().getTenantId())
|
||||
.namespace(f.getTriggerContext().getNamespace())
|
||||
.flowId(f.getTriggerContext().getFlowId())
|
||||
.flowRevision(f.getTriggerContext().getFlowRevision())
|
||||
.triggerId(f.getTriggerContext().getTriggerId())
|
||||
.date(f.getTriggerContext().getNextExecutionDate())
|
||||
.nextExecutionDate(f.getTriggerContext().getNextExecutionDate())
|
||||
|
||||
@@ -345,7 +345,8 @@ public class ExecutionService {
|
||||
state,
|
||||
null,
|
||||
null,
|
||||
null
|
||||
null,
|
||||
true
|
||||
)
|
||||
.map(throwFunction(execution -> {
|
||||
PurgeResult.PurgeResultBuilder<?, ?> builder = PurgeResult.builder();
|
||||
@@ -478,6 +479,7 @@ public class ExecutionService {
|
||||
.executionId(childExecution.getId())
|
||||
.isOnKillCascade(true)
|
||||
.state(ExecutionKilled.State.REQUESTED) // Event will be reentrant in the Executor.
|
||||
.tenantId(tenantId)
|
||||
.build()
|
||||
);
|
||||
}
|
||||
|
||||
@@ -12,13 +12,23 @@ import java.util.List;
|
||||
public class SkipExecutionService {
|
||||
private volatile List<String> skipExecutions = Collections.emptyList();
|
||||
private volatile List<FlowId> skipFlows = Collections.emptyList();
|
||||
private volatile List<NamespaceId> skipNamespaces = Collections.emptyList();
|
||||
private volatile List<String> skipTenants = Collections.emptyList();
|
||||
|
||||
public synchronized void setSkipExecutions(List<String> skipExecutions) {
|
||||
this.skipExecutions = skipExecutions;
|
||||
this.skipExecutions = skipExecutions == null ? Collections.emptyList() : skipExecutions;
|
||||
}
|
||||
|
||||
public synchronized void setSkipFlows(List<String> skipFlows) {
|
||||
this.skipFlows = skipFlows == null ? Collections.emptyList() : skipFlows.stream().map(flow -> FlowId.from(flow)).toList();
|
||||
this.skipFlows = skipFlows == null ? Collections.emptyList() : skipFlows.stream().map(FlowId::from).toList();
|
||||
}
|
||||
|
||||
public synchronized void setSkipNamespaces(List<String> skipNamespaces) {
|
||||
this.skipNamespaces = skipNamespaces == null ? Collections.emptyList() : skipNamespaces.stream().map(NamespaceId::from).toList();
|
||||
}
|
||||
|
||||
public synchronized void setSkipTenants(List<String> skipTenants) {
|
||||
this.skipTenants = skipTenants == null ? Collections.emptyList() : skipTenants;
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -38,17 +48,30 @@ public class SkipExecutionService {
|
||||
|
||||
@VisibleForTesting
|
||||
boolean skipExecution(String tenant, String namespace, String flow, String executionId) {
|
||||
return skipExecutions.contains(executionId) ||
|
||||
skipFlows.contains(new FlowId(tenant, namespace, flow));
|
||||
return (tenant != null && skipTenants.contains(tenant)) ||
|
||||
skipNamespaces.contains(new NamespaceId(tenant, namespace)) ||
|
||||
skipFlows.contains(new FlowId(tenant, namespace, flow)) ||
|
||||
(executionId != null && skipExecutions.contains(executionId));
|
||||
}
|
||||
|
||||
private static String[] splitIdParts(String id) {
|
||||
return id.split("\\|");
|
||||
}
|
||||
|
||||
record FlowId(String tenant, String namespace, String flow) {
|
||||
static FlowId from(String flowId) {
|
||||
String[] parts = flowId.split("\\|");
|
||||
String[] parts = SkipExecutionService.splitIdParts(flowId);
|
||||
if (parts.length == 3) {
|
||||
return new FlowId(parts[0], parts[1], parts[2]);
|
||||
}
|
||||
return new FlowId(null, parts[0], parts[1]);
|
||||
}
|
||||
};
|
||||
|
||||
record NamespaceId(String tenant, String namespace) {
|
||||
static NamespaceId from(String namespaceId) {
|
||||
String[] parts = SkipExecutionService.splitIdParts(namespaceId);
|
||||
return new NamespaceId(parts[0], parts[1]);
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
@@ -152,7 +152,6 @@ abstract public class TestsUtils {
|
||||
.triggerId(trigger.getId())
|
||||
.flowId(flow.getId())
|
||||
.namespace(flow.getNamespace())
|
||||
.flowRevision(flow.getRevision())
|
||||
.date(ZonedDateTime.now())
|
||||
.build();
|
||||
|
||||
|
||||
@@ -270,7 +270,7 @@ public class WorkingDirectory extends Sequential implements NamespaceFilesInterf
|
||||
}
|
||||
}
|
||||
|
||||
if (this.namespaceFiles != null ) {
|
||||
if (this.namespaceFiles != null && Boolean.TRUE.equals(this.namespaceFiles.getEnabled())) {
|
||||
NamespaceFilesService namespaceFilesService = runContext.getApplicationContext().getBean(NamespaceFilesService.class);
|
||||
namespaceFilesService.inject(runContext, taskRun.getTenantId(), taskRun.getNamespace(), runContext.tempDir(), this.namespaceFiles);
|
||||
}
|
||||
|
||||
@@ -21,6 +21,7 @@ import java.net.URI;
|
||||
import java.security.GeneralSecurityException;
|
||||
import java.util.List;
|
||||
import java.util.Map;
|
||||
import java.util.OptionalInt;
|
||||
|
||||
@SuperBuilder
|
||||
@ToString
|
||||
@@ -122,6 +123,16 @@ public class Request extends AbstractHttp implements RunnableTask<Request.Output
|
||||
response = client
|
||||
.toBlocking()
|
||||
.exchange(request, Argument.STRING, Argument.STRING);
|
||||
|
||||
// check that the string is a valid Unicode string
|
||||
if (response.getBody().isPresent()) {
|
||||
OptionalInt illegalChar = response.body().chars().filter(c -> !Character.isDefined(c)).findFirst();
|
||||
if (illegalChar.isPresent()) {
|
||||
throw new IllegalArgumentException("Illegal unicode code point in request body: " + illegalChar.getAsInt() +
|
||||
", the Request task only support valid Unicode strings as body.\n" +
|
||||
"You can try using the Download task instead.");
|
||||
}
|
||||
}
|
||||
} catch (HttpClientResponseException e) {
|
||||
if (!allowFailed) {
|
||||
throw e;
|
||||
|
||||
@@ -80,7 +80,6 @@ public class DeleteFiles extends Task implements RunnableTask<DeleteFiles.Output
|
||||
private String namespace;
|
||||
|
||||
@NotNull
|
||||
@NotEmpty
|
||||
@Schema(
|
||||
title = "A file or a list of files from the given namespace.",
|
||||
description = "String or a list of strings; each string can either be a regex glob pattern or a file path URI.",
|
||||
|
||||
@@ -11,7 +11,6 @@ import io.kestra.core.runners.RunContext;
|
||||
import io.kestra.core.services.FlowService;
|
||||
import io.kestra.core.utils.Rethrow;
|
||||
import io.swagger.v3.oas.annotations.media.Schema;
|
||||
import jakarta.validation.constraints.NotEmpty;
|
||||
import lombok.Builder;
|
||||
import lombok.Getter;
|
||||
import lombok.NoArgsConstructor;
|
||||
@@ -84,7 +83,6 @@ public class DownloadFiles extends Task implements RunnableTask<DownloadFiles.Ou
|
||||
private String namespace;
|
||||
|
||||
@NotNull
|
||||
@NotEmpty
|
||||
@Schema(
|
||||
title = "A file or a list of files from the given namespace.",
|
||||
description = "String or a list of strings; each string can either be a regex glob pattern or a file path URI.",
|
||||
@@ -93,11 +91,19 @@ public class DownloadFiles extends Task implements RunnableTask<DownloadFiles.Ou
|
||||
@PluginProperty(dynamic = true)
|
||||
private Object files;
|
||||
|
||||
@Schema(
|
||||
title = "The folder where the downloaded files will be stored"
|
||||
)
|
||||
@PluginProperty(dynamic = true)
|
||||
@Builder.Default
|
||||
private String destination = "";
|
||||
|
||||
|
||||
@Override
|
||||
public Output run(RunContext runContext) throws Exception {
|
||||
Logger logger = runContext.logger();
|
||||
String renderedNamespace = runContext.render(namespace);
|
||||
String renderedDestination = runContext.render(destination);
|
||||
// Check if namespace is allowed
|
||||
RunContext.FlowInfo flowInfo = runContext.flowInfo();
|
||||
FlowService flowService = runContext.getApplicationContext().getBean(FlowService.class);
|
||||
@@ -120,7 +126,7 @@ public class DownloadFiles extends Task implements RunnableTask<DownloadFiles.Ou
|
||||
namespaceFilesService.recursiveList(flowInfo.tenantId(), renderedNamespace, null).forEach(Rethrow.throwConsumer(uri -> {
|
||||
if (patterns.stream().anyMatch(p -> p.matches(Path.of(uri.getPath())))) {
|
||||
try (InputStream inputStream = namespaceFilesService.content(flowInfo.tenantId(), renderedNamespace, uri)) {
|
||||
downloaded.put(uri.getPath(), runContext.storage().putFile(inputStream, uri.getPath()));
|
||||
downloaded.put(uri.getPath(), runContext.storage().putFile(inputStream, destination + uri.getPath()));
|
||||
logger.debug(String.format("Downloaded %s", uri));
|
||||
}
|
||||
}
|
||||
|
||||
@@ -138,10 +138,10 @@ public class UploadFiles extends Task implements RunnableTask<UploadFiles.Output
|
||||
});
|
||||
|
||||
// check for file in current tempDir that match regexs
|
||||
List<PathMatcher> patterns = regexs.stream().map(reg -> FileSystems.getDefault().getPathMatcher("glob:" + reg)).toList();
|
||||
for (File file : Objects.requireNonNull(runContext.tempDir().toFile().listFiles())) {
|
||||
List<PathMatcher> patterns = regexs.stream().map(reg -> FileSystems.getDefault().getPathMatcher("glob:" + runContext.tempDir().toString() + checkLeadingSlash(reg))).toList();
|
||||
for (File file : Objects.requireNonNull(listFilesRecursively(runContext.tempDir().toFile()))) {
|
||||
if (patterns.stream().anyMatch(p -> p.matches(Path.of(file.toURI().getPath())))) {
|
||||
String newFilePath = buildPath(renderedDestination, file.getName());
|
||||
String newFilePath = buildPath(renderedDestination, file.getPath().replace(runContext.tempDir().toString(), ""));
|
||||
storeNewFile(logger, runContext, storageInterface, flowInfo.tenantId(), newFilePath, new FileInputStream(file));
|
||||
}
|
||||
}
|
||||
@@ -199,6 +199,24 @@ public class UploadFiles extends Task implements RunnableTask<UploadFiles.Output
|
||||
}
|
||||
}
|
||||
|
||||
private List<File> listFilesRecursively(File directory) throws IOException {
|
||||
List<File> files = new ArrayList<>();
|
||||
if (directory == null || !directory.isDirectory()) {
|
||||
return files; // Handle invalid directory or not a directory
|
||||
}
|
||||
|
||||
for (File file : directory.listFiles()) {
|
||||
if (file.isFile()) {
|
||||
files.add(file);
|
||||
} else {
|
||||
// Recursively call for subdirectories
|
||||
files.addAll(listFilesRecursively(file));
|
||||
}
|
||||
}
|
||||
return files;
|
||||
}
|
||||
|
||||
|
||||
@Builder
|
||||
@Getter
|
||||
public static class Output implements io.kestra.core.models.tasks.Output {
|
||||
|
||||
@@ -355,7 +355,7 @@ public class Schedule extends AbstractTrigger implements PollingTriggerInterface
|
||||
.tenantId(triggerContext.getTenantId())
|
||||
.namespace(triggerContext.getNamespace())
|
||||
.flowId(triggerContext.getFlowId())
|
||||
.flowRevision(triggerContext.getFlowRevision())
|
||||
.flowRevision(conditionContext.getFlow().getRevision())
|
||||
.labels(labels)
|
||||
.state(new State().withState(State.Type.FAILED))
|
||||
.build();
|
||||
@@ -399,7 +399,7 @@ public class Schedule extends AbstractTrigger implements PollingTriggerInterface
|
||||
.tenantId(triggerContext.getTenantId())
|
||||
.namespace(triggerContext.getNamespace())
|
||||
.flowId(triggerContext.getFlowId())
|
||||
.flowRevision(triggerContext.getFlowRevision())
|
||||
.flowRevision(conditionContext.getFlow().getRevision())
|
||||
.labels(labels)
|
||||
.state(new State())
|
||||
.trigger(executionTrigger)
|
||||
|
||||
@@ -26,7 +26,6 @@ public abstract class AbstractTriggerRepositoryTest {
|
||||
return Trigger.builder()
|
||||
.flowId(IdUtils.create())
|
||||
.namespace(TEST_NAMESPACE)
|
||||
.flowRevision(1)
|
||||
.triggerId(IdUtils.create())
|
||||
.executionId(IdUtils.create())
|
||||
.date(ZonedDateTime.now());
|
||||
|
||||
@@ -88,8 +88,7 @@ public class DeserializationIssuesCaseTest {
|
||||
"date": "2023-11-24T15:48:57.632881597Z",
|
||||
"flowId": "http-trigger",
|
||||
"namespace": "dev",
|
||||
"triggerId": "http",
|
||||
"flowRevision": 3
|
||||
"triggerId": "http"
|
||||
},
|
||||
"conditionContext": {
|
||||
"flow": {
|
||||
|
||||
@@ -34,6 +34,13 @@ class FilesServiceTest {
|
||||
assertThat(content.get("file.txt"), is("Hello World"));
|
||||
}
|
||||
|
||||
@Test
|
||||
void renderRawFile() throws Exception {
|
||||
RunContext runContext = runContextFactory.of(Map.of("filename", "file.txt", "content", "Hello World"));
|
||||
Map<String, String> content = FilesService.inputFiles(runContext, Map.of("{{filename}}", "{% raw %}{{content}}{% endraw %}"));
|
||||
assertThat(content.get("file.txt"), is("{{content}}"));
|
||||
}
|
||||
|
||||
@Test
|
||||
void outputFiles() throws Exception {
|
||||
RunContext runContext = runContextFactory.of();
|
||||
|
||||
@@ -104,6 +104,13 @@ abstract public class FlowListenersTest {
|
||||
assertThat(count.get(), is(2));
|
||||
assertThat(flowListenersService.flows().size(), is(2));
|
||||
});
|
||||
|
||||
Flow withTenant = first.toBuilder().tenantId("some-tenant").build();
|
||||
flowRepository.create(withTenant, withTenant.generateSource(), pluginDefaultService.injectDefaults(withTenant));
|
||||
wait(ref, () -> {
|
||||
assertThat(count.get(), is(3));
|
||||
assertThat(flowListenersService.flows().size(), is(3));
|
||||
});
|
||||
}
|
||||
|
||||
public static class Ref {
|
||||
|
||||
@@ -1,9 +1,13 @@
|
||||
package io.kestra.core.runners;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.contains;
|
||||
|
||||
import io.kestra.core.exceptions.IllegalVariableEvaluationException;
|
||||
import io.micronaut.context.ApplicationContext;
|
||||
import io.micronaut.test.extensions.junit5.annotation.MicronautTest;
|
||||
import jakarta.inject.Inject;
|
||||
import java.util.LinkedHashMap;
|
||||
import org.junit.jupiter.api.Assertions;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
@@ -18,6 +22,9 @@ class VariableRendererTest {
|
||||
@Inject
|
||||
VariableRenderer.VariableConfiguration variableConfiguration;
|
||||
|
||||
@Inject
|
||||
VariableRenderer variableRenderer;
|
||||
|
||||
@Test
|
||||
void shouldRenderUsingAlternativeRendering() throws IllegalVariableEvaluationException {
|
||||
TestVariableRenderer renderer = new TestVariableRenderer(applicationContext, variableConfiguration);
|
||||
@@ -25,6 +32,25 @@ class VariableRendererTest {
|
||||
Assertions.assertEquals("result", render);
|
||||
}
|
||||
|
||||
@Test
|
||||
void shouldKeepKeyOrderWhenRenderingMap() throws IllegalVariableEvaluationException {
|
||||
final Map<String, Object> input = new LinkedHashMap<>();
|
||||
input.put("foo-1", "A");
|
||||
input.put("foo-2", "B");
|
||||
|
||||
final Map<String, Object> input_value3 = new LinkedHashMap<>();
|
||||
input_value3.put("bar-1", "C");
|
||||
input_value3.put("bar-2", "D");
|
||||
input_value3.put("bar-3", "E");
|
||||
//
|
||||
input.put("foo-3", input_value3);
|
||||
|
||||
final Map<String, Object> result = variableRenderer.render(input, Map.of());
|
||||
assertThat(result.keySet(), contains("foo-1", "foo-2", "foo-3"));
|
||||
|
||||
final Map<String, Object> result_value3 = (Map<String, Object>) result.get("foo-3");
|
||||
assertThat(result_value3.keySet(), contains("bar-1", "bar-2", "bar-3"));
|
||||
}
|
||||
|
||||
public static class TestVariableRenderer extends VariableRenderer {
|
||||
|
||||
|
||||
@@ -104,7 +104,7 @@ abstract public class AbstractSchedulerTest {
|
||||
.id(IdUtils.create())
|
||||
.namespace(context.getNamespace())
|
||||
.flowId(context.getFlowId())
|
||||
.flowRevision(context.getFlowRevision())
|
||||
.flowRevision(conditionContext.getFlow().getRevision())
|
||||
.state(new State())
|
||||
.trigger(ExecutionTrigger.builder()
|
||||
.id(this.getId())
|
||||
|
||||
@@ -65,7 +65,6 @@ class SchedulerConditionTest extends AbstractSchedulerTest {
|
||||
triggerState.create(Trigger.builder()
|
||||
.namespace(flow.getNamespace())
|
||||
.flowId(flow.getId())
|
||||
.flowRevision(flow.getRevision())
|
||||
.triggerId("hourly")
|
||||
.date(ZonedDateTime.parse("2021-09-06T02:00:00+01:00[Europe/Paris]"))
|
||||
.build()
|
||||
|
||||
@@ -21,7 +21,6 @@ public abstract class SchedulerTriggerStateInterfaceTest {
|
||||
return Trigger.builder()
|
||||
.flowId(IdUtils.create())
|
||||
.namespace("io.kestra.unittest")
|
||||
.flowRevision(1)
|
||||
.triggerId(IdUtils.create())
|
||||
.executionId(IdUtils.create())
|
||||
.date(ZonedDateTime.now());
|
||||
|
||||
@@ -4,6 +4,7 @@ import io.kestra.core.models.executions.Execution;
|
||||
import io.kestra.core.models.executions.TaskRun;
|
||||
import io.micronaut.test.extensions.junit5.annotation.MicronautTest;
|
||||
import jakarta.inject.Inject;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
|
||||
import java.util.List;
|
||||
@@ -16,6 +17,14 @@ class SkipExecutionServiceTest {
|
||||
@Inject
|
||||
private SkipExecutionService skipExecutionService;
|
||||
|
||||
@BeforeEach
|
||||
void resetAll() {
|
||||
skipExecutionService.setSkipExecutions(null);
|
||||
skipExecutionService.setSkipFlows(null);
|
||||
skipExecutionService.setSkipNamespaces(null);
|
||||
skipExecutionService.setSkipTenants(null);
|
||||
}
|
||||
|
||||
@Test
|
||||
void skipExecutionByExecutionId() {
|
||||
var executionToSkip = "aaabbbccc";
|
||||
@@ -65,4 +74,25 @@ class SkipExecutionServiceTest {
|
||||
assertThat(skipExecutionService.skipExecution(null, "namespace", "not_skipped", "random"), is(false));
|
||||
assertThat(skipExecutionService.skipExecution("tenant", "namespace", "not_skipped", "random"), is(false));
|
||||
}
|
||||
|
||||
@Test
|
||||
void skipExecutionByNamespace() {
|
||||
skipExecutionService.setSkipNamespaces(List.of("tenant|namespace"));
|
||||
|
||||
assertThat(skipExecutionService.skipExecution("tenant", "namespace", "someFlow", "someExecution"), is(true));
|
||||
assertThat(skipExecutionService.skipExecution(null, "namespace", "someFlow", "someExecution"), is(false));
|
||||
assertThat(skipExecutionService.skipExecution("anotherTenant", "namespace", "someFlow", "someExecution"), is(false));
|
||||
assertThat(skipExecutionService.skipExecution("tenant", "namespace", "anotherFlow", "anotherExecution"), is(true));
|
||||
assertThat(skipExecutionService.skipExecution("tenant", "other.namespace", "someFlow", "someExecution"), is(false));
|
||||
}
|
||||
|
||||
@Test
|
||||
void skipExecutionByTenantId() {
|
||||
skipExecutionService.setSkipTenants(List.of("tenant"));
|
||||
|
||||
assertThat(skipExecutionService.skipExecution("tenant", "namespace", "someFlow", "someExecution"), is(true));
|
||||
assertThat(skipExecutionService.skipExecution("anotherTenant", "namespace", "someFlow", "someExecution"), is(false));
|
||||
assertThat(skipExecutionService.skipExecution("tenant", "another.namespace", "someFlow", "someExecution"), is(true));
|
||||
assertThat(skipExecutionService.skipExecution("anotherTenant", "another.namespace", "someFlow", "someExecution"), is(false));
|
||||
}
|
||||
}
|
||||
@@ -6,22 +6,23 @@ import io.kestra.core.models.executions.Execution;
|
||||
import io.kestra.core.models.executions.TaskRun;
|
||||
import io.kestra.core.models.flows.Flow;
|
||||
import io.kestra.core.models.flows.State;
|
||||
import io.kestra.core.models.tasks.common.EncryptedString;
|
||||
import io.kestra.core.runners.AbstractMemoryRunnerTest;
|
||||
import io.kestra.core.runners.RunContextFactory;
|
||||
import io.kestra.core.runners.RunnerUtils;
|
||||
import io.kestra.core.storages.InternalStorage;
|
||||
import io.kestra.core.storages.StorageContext;
|
||||
import io.kestra.core.storages.StorageInterface;
|
||||
import io.kestra.core.utils.IdUtils;
|
||||
import jakarta.inject.Inject;
|
||||
import jakarta.inject.Singleton;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.junitpioneer.jupiter.RetryingTest;
|
||||
|
||||
import java.io.ByteArrayInputStream;
|
||||
import java.io.File;
|
||||
import java.io.IOException;
|
||||
import java.io.InputStream;
|
||||
import java.net.URI;
|
||||
import java.nio.file.Files;
|
||||
import java.security.GeneralSecurityException;
|
||||
import java.time.Duration;
|
||||
import java.util.Collections;
|
||||
import java.util.List;
|
||||
@@ -30,7 +31,6 @@ import java.util.concurrent.TimeoutException;
|
||||
|
||||
import static org.hamcrest.MatcherAssert.assertThat;
|
||||
import static org.hamcrest.Matchers.*;
|
||||
import static org.hamcrest.io.FileMatchers.anExistingFile;
|
||||
import static org.junit.jupiter.api.Assertions.assertFalse;
|
||||
import static org.junit.jupiter.api.Assertions.assertTrue;
|
||||
|
||||
@@ -38,6 +38,9 @@ public class WorkingDirectoryTest extends AbstractMemoryRunnerTest {
|
||||
@Inject
|
||||
Suite suite;
|
||||
|
||||
@Inject
|
||||
RunContextFactory runContextFactory;
|
||||
|
||||
@Test
|
||||
void success() throws TimeoutException {
|
||||
suite.success(runnerUtils);
|
||||
@@ -83,6 +86,11 @@ public class WorkingDirectoryTest extends AbstractMemoryRunnerTest {
|
||||
suite.outputFiles(runnerUtils);
|
||||
}
|
||||
|
||||
@Test
|
||||
void encryption() throws Exception {
|
||||
suite.encryption(runnerUtils, runContextFactory);
|
||||
}
|
||||
|
||||
@Singleton
|
||||
public static class Suite {
|
||||
@Inject
|
||||
@@ -154,8 +162,15 @@ public class WorkingDirectoryTest extends AbstractMemoryRunnerTest {
|
||||
storageContext
|
||||
, storageInterface
|
||||
);
|
||||
URI fileURI = URI.create("kestra:" + storageContext.getContextStorageURI() + "/input.txt");
|
||||
assertThat(new String(storage.getFile(fileURI).readAllBytes()), is("Hello World"));
|
||||
|
||||
TaskRun taskRun = execution.getTaskRunList().get(1);
|
||||
Map<String, Object> outputs = taskRun.getOutputs();
|
||||
assertThat(outputs, hasKey("uris"));
|
||||
|
||||
URI uri = URI.create(((Map<String, String>) outputs.get("uris")).get("input.txt"));
|
||||
|
||||
assertTrue(uri.toString().endsWith("input.txt"));
|
||||
assertThat(new String(storage.getFile(uri).readAllBytes()), is("Hello World"));
|
||||
}
|
||||
|
||||
@SuppressWarnings("unchecked")
|
||||
@@ -236,6 +251,18 @@ public class WorkingDirectoryTest extends AbstractMemoryRunnerTest {
|
||||
assertThat(execution.findTaskRunsByTaskId("t3").get(0).getOutputs().get("value"), is("third"));
|
||||
}
|
||||
|
||||
public void encryption(RunnerUtils runnerUtils, RunContextFactory runContextFactory) throws TimeoutException, GeneralSecurityException {
|
||||
Execution execution = runnerUtils.runOne(null, "io.kestra.tests", "working-directory-taskrun-encrypted");
|
||||
|
||||
assertThat(execution.getTaskRunList(), hasSize(3));
|
||||
Map<String, Object> encryptedString = (Map<String, Object>) execution.findTaskRunsByTaskId("encrypted").get(0).getOutputs().get("value");
|
||||
assertThat(encryptedString.get("type"), is(EncryptedString.TYPE));
|
||||
String encryptedValue = (String) encryptedString.get("value");
|
||||
assertThat(encryptedValue, is(not("Hello World")));
|
||||
assertThat(runContextFactory.of().decrypt(encryptedValue), is("Hello World"));
|
||||
assertThat(execution.findTaskRunsByTaskId("decrypted").get(0).getOutputs().get("value"), is("Hello World"));
|
||||
}
|
||||
|
||||
private void put(String path, String content) throws IOException {
|
||||
storageInterface.put(
|
||||
null,
|
||||
|
||||
@@ -65,7 +65,6 @@ class ScheduleTest {
|
||||
return TriggerContext.builder()
|
||||
.namespace(flow.getNamespace())
|
||||
.flowId(flow.getNamespace())
|
||||
.flowRevision(flow.getRevision())
|
||||
.triggerId(schedule.getId())
|
||||
.date(date)
|
||||
.build();
|
||||
|
||||
@@ -0,0 +1,13 @@
|
||||
id: working-directory-taskrun-encrypted
|
||||
namespace: io.kestra.tests
|
||||
|
||||
tasks:
|
||||
- id: workingDir
|
||||
type: io.kestra.plugin.core.flow.WorkingDirectory
|
||||
tasks:
|
||||
- id: encrypted
|
||||
type: io.kestra.core.tasks.test.Encrypted
|
||||
format: "Hello World"
|
||||
- id: decrypted
|
||||
type: io.kestra.plugin.core.debug.Return
|
||||
format: "{{outputs.encrypted.value}}"
|
||||
@@ -1,4 +1,4 @@
|
||||
version=0.17.0
|
||||
version=0.17.13
|
||||
|
||||
jacksonVersion=2.16.2
|
||||
micronautVersion=4.4.3
|
||||
@@ -7,4 +7,4 @@ slf4jVersion=2.0.13
|
||||
|
||||
org.gradle.parallel=true
|
||||
org.gradle.caching=true
|
||||
org.gradle.priority=low
|
||||
org.gradle.priority=low
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
datasources:
|
||||
h2:
|
||||
url: jdbc:h2:mem:public;DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE
|
||||
url: jdbc:h2:mem:public;TIME ZONE=UTC;DB_CLOSE_DELAY=-1;DB_CLOSE_ON_EXIT=FALSE
|
||||
username: sa
|
||||
password: ""
|
||||
driverClassName: org.h2.Driver
|
||||
|
||||
@@ -172,7 +172,8 @@ public abstract class AbstractJdbcExecutionRepository extends AbstractJdbcReposi
|
||||
state,
|
||||
labels,
|
||||
triggerExecutionId,
|
||||
childFilter
|
||||
childFilter,
|
||||
false
|
||||
);
|
||||
|
||||
return this.jdbcRepository.fetchPage(context, select, pageable);
|
||||
@@ -190,7 +191,8 @@ public abstract class AbstractJdbcExecutionRepository extends AbstractJdbcReposi
|
||||
@Nullable List<State.Type> state,
|
||||
@Nullable Map<String, String> labels,
|
||||
@Nullable String triggerExecutionId,
|
||||
@Nullable ChildFilter childFilter
|
||||
@Nullable ChildFilter childFilter,
|
||||
boolean deleted
|
||||
) {
|
||||
return Flux.create(
|
||||
emitter -> this.jdbcRepository
|
||||
@@ -209,7 +211,8 @@ public abstract class AbstractJdbcExecutionRepository extends AbstractJdbcReposi
|
||||
state,
|
||||
labels,
|
||||
triggerExecutionId,
|
||||
childFilter
|
||||
childFilter,
|
||||
deleted
|
||||
);
|
||||
|
||||
select.fetch()
|
||||
@@ -233,7 +236,8 @@ public abstract class AbstractJdbcExecutionRepository extends AbstractJdbcReposi
|
||||
@Nullable List<State.Type> state,
|
||||
@Nullable Map<String, String> labels,
|
||||
@Nullable String triggerExecutionId,
|
||||
@Nullable ChildFilter childFilter
|
||||
@Nullable ChildFilter childFilter,
|
||||
boolean deleted
|
||||
) {
|
||||
SelectConditionStep<Record1<Object>> select = context
|
||||
.select(
|
||||
@@ -241,7 +245,7 @@ public abstract class AbstractJdbcExecutionRepository extends AbstractJdbcReposi
|
||||
)
|
||||
.hint(context.configuration().dialect() == SQLDialect.MYSQL ? "SQL_CALC_FOUND_ROWS" : null)
|
||||
.from(this.jdbcRepository.getTable())
|
||||
.where(this.defaultFilter(tenantId));
|
||||
.where(this.defaultFilter(tenantId, deleted));
|
||||
|
||||
select = filteringQuery(select, namespace, flowId, null, query, labels, triggerExecutionId, childFilter);
|
||||
|
||||
|
||||
@@ -23,6 +23,11 @@ public abstract class AbstractJdbcRepository {
|
||||
return tenant.and(field("deleted", Boolean.class).eq(false));
|
||||
}
|
||||
|
||||
protected Condition defaultFilter(String tenantId, Boolean allowDeleted) {
|
||||
var tenant = buildTenantCondition(tenantId);
|
||||
return allowDeleted ? tenant : tenant.and(field("deleted", Boolean.class).eq(false));
|
||||
}
|
||||
|
||||
protected Condition buildTenantCondition(String tenantId) {
|
||||
return tenantId == null ? field("tenant_id").isNull() : field("tenant_id").eq(tenantId);
|
||||
}
|
||||
|
||||
@@ -706,6 +706,7 @@ public class JdbcExecutor implements ExecutorInterface, Service {
|
||||
.executionId(killedExecution.getExecutionId())
|
||||
.isOnKillCascade(false)
|
||||
.state(ExecutionKilled.State.EXECUTED)
|
||||
.tenantId(killedExecution.getTenantId())
|
||||
.build()
|
||||
);
|
||||
|
||||
|
||||
@@ -38,6 +38,11 @@ public class MemoryExecutionRepository implements ExecutionRepositoryInterface {
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public Flux<Execution> find(@Nullable String query, @Nullable String tenantId, @Nullable String namespace, @Nullable String flowId, @Nullable ZonedDateTime startDate, @Nullable ZonedDateTime endDate, @Nullable List<State.Type> state, @Nullable Map<String, String> labels, @Nullable String triggerExecutionId, @Nullable ChildFilter childFilter, boolean allowDeleted) {
|
||||
return null;
|
||||
}
|
||||
|
||||
@Override
|
||||
public ArrayListTotal<TaskRun> findTaskRun(Pageable pageable, @Nullable String query, @Nullable String tenantId, @Nullable String namespace, @Nullable String flowId, @Nullable ZonedDateTime startDate, @Nullable ZonedDateTime endDate, @Nullable List<State.Type> states, @Nullable Map<String, String> labels, @Nullable String triggerExecutionId, @Nullable ChildFilter childFilter) {
|
||||
throw new UnsupportedOperationException();
|
||||
|
||||
@@ -131,10 +131,10 @@ public class CommandsWrapper implements TaskCommands {
|
||||
@SuppressWarnings("unchecked")
|
||||
public ScriptOutput run() throws Exception {
|
||||
List<String> filesToUpload = new ArrayList<>();
|
||||
if (this.namespaceFiles != null) {
|
||||
String tenantId = ((Map<String, String>) runContext.getVariables().get("flow")).get("tenantId");
|
||||
String namespace = ((Map<String, String>) runContext.getVariables().get("flow")).get("namespace");
|
||||
String tenantId = ((Map<String, String>) runContext.getVariables().get("flow")).get("tenantId");
|
||||
String namespace = ((Map<String, String>) runContext.getVariables().get("flow")).get("namespace");
|
||||
|
||||
if (this.namespaceFiles != null && Boolean.TRUE.equals(this.namespaceFiles.getEnabled())) {
|
||||
NamespaceFilesService namespaceFilesService = runContext.getApplicationContext().getBean(NamespaceFilesService.class);
|
||||
List<URI> injectedFiles = namespaceFilesService.inject(
|
||||
runContext,
|
||||
|
||||
@@ -78,7 +78,7 @@ public class LocalStorage implements StorageInterface {
|
||||
|
||||
@Override
|
||||
public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) {
|
||||
uris.add(URI.create(file.toString()));
|
||||
uris.add(URI.create(file.toString().replace("\\", "/")));
|
||||
return FileVisitResult.CONTINUE;
|
||||
}
|
||||
|
||||
@@ -90,7 +90,7 @@ public class LocalStorage implements StorageInterface {
|
||||
}
|
||||
});
|
||||
|
||||
URI fsPathUri = URI.create(fsPath.toString());
|
||||
URI fsPathUri = URI.create(fsPath.toString().replace("\\", "/"));
|
||||
return uris.stream().sorted(Comparator.reverseOrder())
|
||||
.map(fsPathUri::relativize)
|
||||
.map(URI::getPath)
|
||||
@@ -115,7 +115,7 @@ public class LocalStorage implements StorageInterface {
|
||||
URI relative = URI.create(
|
||||
getPath(tenantId, null).relativize(
|
||||
Path.of(file.toUri())
|
||||
).toString()
|
||||
).toString().replace("\\", "/")
|
||||
);
|
||||
return getAttributes(tenantId, relative);
|
||||
}))
|
||||
|
||||
1884
ui/package-lock.json
generated
1884
ui/package-lock.json
generated
File diff suppressed because it is too large
Load Diff
@@ -12,20 +12,20 @@
|
||||
"lint": "eslint . --ext .vue,.js,.jsx,.cjs,.mjs --fix"
|
||||
},
|
||||
"dependencies": {
|
||||
"@kestra-io/ui-libs": "^0.0.47",
|
||||
"@kestra-io/ui-libs": "^0.0.48",
|
||||
"@vue-flow/background": "^1.3.0",
|
||||
"@vue-flow/controls": "^1.1.1",
|
||||
"@vue-flow/core": "^1.33.6",
|
||||
"ansi-to-html": "^0.7.2",
|
||||
"axios": "^1.6.8",
|
||||
"axios": "^1.7.2",
|
||||
"bootstrap": "^5.3.3",
|
||||
"buffer": "^6.0.3",
|
||||
"chart.js": "^4.4.2",
|
||||
"chart.js": "^4.4.3",
|
||||
"chartjs-chart-treemap": "^2.3.1",
|
||||
"core-js": "^3.37.0",
|
||||
"core-js": "^3.37.1",
|
||||
"dagre": "^0.8.5",
|
||||
"element-plus": "^2.7.2",
|
||||
"humanize-duration": "^3.32.0",
|
||||
"element-plus": "^2.7.5",
|
||||
"humanize-duration": "^3.32.1",
|
||||
"js-yaml": "^4.1.0",
|
||||
"lodash": "^4.17.21",
|
||||
"markdown-it": "^14.1.0",
|
||||
@@ -40,45 +40,49 @@
|
||||
"moment-timezone": "^0.5.45",
|
||||
"node-modules-polyfill": "^0.1.4",
|
||||
"nprogress": "^0.2.0",
|
||||
"posthog-js": "^1.130.2",
|
||||
"posthog-js": "^1.138.2",
|
||||
"cronstrue": "^2.50.0",
|
||||
"throttle-debounce": "^5.0.0",
|
||||
"vite-plugin-eslint": "^1.8.1",
|
||||
"vue": "^3.4.26",
|
||||
"vue": "^3.4.27",
|
||||
"vue-axios": "3.5.2",
|
||||
"vue-chartjs": "^5.3.1",
|
||||
"vue-gtag": "^2.0.1",
|
||||
"vue-i18n": "^9.13.1",
|
||||
"vue-material-design-icons": "^5.3.0",
|
||||
"vue-router": "^4.3.2",
|
||||
"vue-sidebar-menu": "^5.3.1",
|
||||
"vue-sidebar-menu": "^5.4.0",
|
||||
"vue-virtual-scroller": "^2.0.0-beta.8",
|
||||
"vue3-popper": "^1.5.0",
|
||||
"vue3-tour": "github:kestra-io/vue3-tour",
|
||||
"vuex": "^4.1.0",
|
||||
"xss": "^1.0.15",
|
||||
"yaml": "^2.4.2"
|
||||
"yaml": "^2.4.5"
|
||||
},
|
||||
"devDependencies": {
|
||||
"@rushstack/eslint-patch": "^1.10.2",
|
||||
"@shikijs/markdown-it": "^1.4.0",
|
||||
"@typescript-eslint/parser": "^7.8.0",
|
||||
"@vitejs/plugin-vue": "^5.0.4",
|
||||
"@rushstack/eslint-patch": "^1.10.3",
|
||||
"@shikijs/markdown-it": "^1.6.3",
|
||||
"@typescript-eslint/parser": "^7.12.0",
|
||||
"@vitejs/plugin-vue": "^5.0.5",
|
||||
"@vue/eslint-config-prettier": "^9.0.0",
|
||||
"@vue/test-utils": "^2.4.5",
|
||||
"@vue/test-utils": "^2.4.6",
|
||||
"decompress": "^4.2.1",
|
||||
"eslint": "^8.57.0",
|
||||
"eslint-plugin-vue": "^9.25.0",
|
||||
"jsdom": "^24.0.0",
|
||||
"monaco-editor": "^0.48.0",
|
||||
"monaco-yaml": "^5.1.1",
|
||||
"prettier": "^3.2.5",
|
||||
"eslint-plugin-vue": "^9.26.0",
|
||||
"jsdom": "^24.1.0",
|
||||
"monaco-editor": "^0.49.0",
|
||||
"monaco-yaml": "^5.2.0",
|
||||
"prettier": "^3.3.1",
|
||||
"rollup-plugin-copy": "^3.5.0",
|
||||
"rollup-plugin-visualizer": "^5.12.0",
|
||||
"sass": "^1.76.0",
|
||||
"sass": "^1.77.4",
|
||||
"typescript": "^5.4.5",
|
||||
"vite": "^5.2.11",
|
||||
"vite-plugin-rewrite-all": "1.0.1",
|
||||
"vitest": "^1.5.3"
|
||||
"vite": "^5.2.13",
|
||||
"vitest": "^1.6.0"
|
||||
},
|
||||
"optionalDependencies": {
|
||||
"@rollup/rollup-linux-x64-gnu": "4.18.0"
|
||||
},
|
||||
"overrides": {
|
||||
"bootstrap": {
|
||||
|
||||
@@ -209,7 +209,7 @@
|
||||
},
|
||||
watch: {
|
||||
$route(to) {
|
||||
if (this.user && to.name === "home" && this.overallTotal === 0) {
|
||||
if (to.name === "home" && this.overallTotal === 0) {
|
||||
this.$router.push({
|
||||
name: "welcome",
|
||||
params: {
|
||||
|
||||
BIN
ui/src/assets/errors/kestra-error.png
Normal file
BIN
ui/src/assets/errors/kestra-error.png
Normal file
Binary file not shown.
|
After Width: | Height: | Size: 73 KiB |
File diff suppressed because one or more lines are too long
|
Before Width: | Height: | Size: 4.9 KiB |
@@ -1,6 +1,10 @@
|
||||
<template>
|
||||
<el-tooltip :persistent="false" :focus-on-show="true" popper-class="ee-tooltip" :disabled="!disabled" :placement="placement">
|
||||
<el-tooltip :visible="visible" :persistent="false" :focus-on-show="true" popper-class="ee-tooltip" :disabled="!disabled" :placement="placement">
|
||||
<template #content v-if="link">
|
||||
<el-button circle class="ee-tooltip-close" @click="changeVisibility(false)">
|
||||
<Close />
|
||||
</el-button>
|
||||
|
||||
<p>{{ $t("ee-tooltip.features-blocked") }}</p>
|
||||
|
||||
<a
|
||||
@@ -13,7 +17,7 @@
|
||||
</a>
|
||||
</template>
|
||||
<template #default>
|
||||
<span ref="slot-container">
|
||||
<span ref="slot-container" class="cursor-pointer" @click="changeVisibility()">
|
||||
<slot />
|
||||
<lock v-if="disabled" />
|
||||
</span>
|
||||
@@ -22,10 +26,11 @@
|
||||
</template>
|
||||
|
||||
<script>
|
||||
import Close from "vue-material-design-icons/Close.vue";
|
||||
import Lock from "vue-material-design-icons/Lock.vue";
|
||||
|
||||
export default {
|
||||
components: {Lock},
|
||||
components: {Close, Lock},
|
||||
props: {
|
||||
top: {
|
||||
type: Boolean,
|
||||
@@ -48,6 +53,16 @@
|
||||
default: undefined
|
||||
},
|
||||
},
|
||||
data() {
|
||||
return {
|
||||
visible: false,
|
||||
}
|
||||
},
|
||||
methods: {
|
||||
changeVisibility(visible = true) {
|
||||
this.visible = visible
|
||||
}
|
||||
},
|
||||
computed: {
|
||||
link() {
|
||||
|
||||
@@ -83,5 +98,13 @@
|
||||
:deep(.material-design-icon) > .material-design-icon__svg {
|
||||
bottom: -0.125em;
|
||||
}
|
||||
|
||||
.ee-tooltip-close {
|
||||
position: absolute;
|
||||
top: 0;
|
||||
right: 0;
|
||||
border: none;
|
||||
margin: 0.5rem;
|
||||
}
|
||||
</style>
|
||||
|
||||
|
||||
@@ -7,6 +7,10 @@
|
||||
<p>
|
||||
<span v-html="$t('errors.' + code + '.content')" />
|
||||
</p>
|
||||
|
||||
<el-button tag="router-link" :to="{name: 'home'}" type="primary">
|
||||
{{ $t("back_to_dashboard") }}
|
||||
</el-button>
|
||||
</section>
|
||||
</template>
|
||||
|
||||
@@ -42,19 +46,23 @@
|
||||
|
||||
<style lang="scss" scoped>
|
||||
.errors {
|
||||
h2 {
|
||||
margin-bottom: calc(var(--spacer) * 2);
|
||||
}
|
||||
|
||||
width: 100%;
|
||||
margin-top: 10em;
|
||||
text-align: center;
|
||||
|
||||
.img {
|
||||
display: inline-block;
|
||||
background: url("../../assets/errors/sorry.svg") no-repeat;
|
||||
background: url("../../assets/errors/kestra-error.png") no-repeat center;
|
||||
background-size: contain;
|
||||
height: 300px;
|
||||
width: 300px;
|
||||
}
|
||||
|
||||
h2 {
|
||||
line-height: 30px;
|
||||
font-size: 20px;
|
||||
font-weight: 600;
|
||||
}
|
||||
|
||||
p {
|
||||
line-height: 22px;
|
||||
font-size: 14px;
|
||||
}
|
||||
}
|
||||
</style>
|
||||
|
||||
@@ -69,6 +69,14 @@
|
||||
if (oldValue.name === newValue.name && this.previousExecutionId !== this.$route.params.id) {
|
||||
this.follow()
|
||||
}
|
||||
// if we change the execution id, we need to close the sse
|
||||
if (this.$route.params.id != this.execution.id) {
|
||||
this.closeSSE();
|
||||
window.removeEventListener("popstate", this.follow)
|
||||
this.$store.commit("execution/setExecution", undefined);
|
||||
this.$store.commit("flow/setFlow", undefined);
|
||||
this.$store.commit("flow/setFlowGraph", undefined);
|
||||
}
|
||||
},
|
||||
},
|
||||
methods: {
|
||||
@@ -91,13 +99,16 @@
|
||||
}
|
||||
// sse.onerror doesnt return the details of the error
|
||||
// but as our emitter can only throw an error on 404
|
||||
// we can safely assume that the error
|
||||
// we can safely assume that the error is a 404
|
||||
// if execution is not defined
|
||||
this.sse.onerror = () => {
|
||||
this.$store.dispatch("core/showMessage", {
|
||||
variant: "error",
|
||||
title: this.$t("error"),
|
||||
message: this.$t("errors.404.flow or execution"),
|
||||
});
|
||||
if (!this.execution) {
|
||||
this.$store.dispatch("core/showMessage", {
|
||||
variant: "error",
|
||||
title: this.$t("error"),
|
||||
message: this.$t("errors.404.flow or execution"),
|
||||
});
|
||||
}
|
||||
}
|
||||
});
|
||||
},
|
||||
|
||||
@@ -425,6 +425,8 @@
|
||||
import {ElMessageBox, ElSwitch, ElFormItem, ElAlert} from "element-plus";
|
||||
import {h, ref} from "vue";
|
||||
|
||||
import {filterLabels} from "./utils"
|
||||
|
||||
export default {
|
||||
mixins: [RouteContext, RestoreUrl, DataTableActions, SelectTableActions],
|
||||
components: {
|
||||
@@ -809,6 +811,13 @@
|
||||
);
|
||||
},
|
||||
setLabels() {
|
||||
const filtered = filterLabels(this.executionLabels)
|
||||
|
||||
if(filtered.error) {
|
||||
this.$toast().error(this.$t("wrong labels"))
|
||||
return;
|
||||
}
|
||||
|
||||
this.$toast().confirm(
|
||||
this.$t("bulk set labels", {"executionCount": this.queryBulkAction ? this.total : this.selection.length}),
|
||||
() => {
|
||||
@@ -819,7 +828,7 @@
|
||||
sort: this.$route.query.sort || "state.startDate:desc",
|
||||
state: this.$route.query.state ? [this.$route.query.state] : this.statuses
|
||||
}, false),
|
||||
data: this.executionLabels
|
||||
data: filtered.labels
|
||||
})
|
||||
.then(r => {
|
||||
this.$toast().success(this.$t("Set labels done", {executionCount: r.data.count}));
|
||||
@@ -829,7 +838,7 @@
|
||||
return this.$store
|
||||
.dispatch("execution/bulkSetLabels", {
|
||||
executionsId: this.selection,
|
||||
executionLabels: this.executionLabels
|
||||
executionLabels: filtered.labels
|
||||
})
|
||||
.then(r => {
|
||||
this.$toast().success(this.$t("Set labels done", {executionCount: r.data.count}));
|
||||
|
||||
@@ -53,6 +53,8 @@
|
||||
import LabelInput from "../../components/labels/LabelInput.vue";
|
||||
import State from "../../utils/state";
|
||||
|
||||
import {filterLabels} from "./utils"
|
||||
|
||||
export default {
|
||||
components: {LabelInput,},
|
||||
props: {
|
||||
@@ -71,9 +73,16 @@
|
||||
},
|
||||
methods: {
|
||||
setLabels() {
|
||||
const filtered = filterLabels(this.executionLabels)
|
||||
|
||||
if(filtered.error) {
|
||||
this.$toast().error(this.$t("wrong labels"))
|
||||
return;
|
||||
}
|
||||
|
||||
this.isOpen = false;
|
||||
this.$store.dispatch("execution/setLabels", {
|
||||
labels: this.executionLabels,
|
||||
labels: filtered.labels,
|
||||
executionId: this.execution.id
|
||||
}).then(response => {
|
||||
this.$store.commit("execution/setExecution", response.data)
|
||||
|
||||
@@ -16,6 +16,7 @@
|
||||
:start-date="startDate"
|
||||
:end-date="endDate"
|
||||
@update:model-value="onAbsFilterChange"
|
||||
class="w-auto"
|
||||
/>
|
||||
<relative-date-select
|
||||
v-if="selectedFilterType === filterType.RELATIVE"
|
||||
|
||||
14
ui/src/components/executions/utils.ts
Normal file
14
ui/src/components/executions/utils.ts
Normal file
@@ -0,0 +1,14 @@
|
||||
interface Label {
|
||||
key: string | null;
|
||||
value: string | null;
|
||||
}
|
||||
|
||||
interface FilterResult {
|
||||
labels: Label[];
|
||||
error?: boolean;
|
||||
}
|
||||
|
||||
export const filterLabels = (labels: Label[]): FilterResult => {
|
||||
const invalid = labels.some(label => label.key === null || label.value === null);
|
||||
return invalid ? {labels, error: true} : {labels};
|
||||
};
|
||||
@@ -41,7 +41,7 @@
|
||||
if (this.$route.query.reset) {
|
||||
localStorage.setItem("tourDoneOrSkip", undefined);
|
||||
this.$store.commit("core/setGuidedProperties", {tourStarted: false});
|
||||
this.$tours["guidedTour"].start();
|
||||
this.$tours["guidedTour"]?.start();
|
||||
}
|
||||
this.setupFlow()
|
||||
},
|
||||
|
||||
@@ -67,7 +67,7 @@
|
||||
},
|
||||
methods: {
|
||||
stopTour() {
|
||||
this.$tours["guidedTour"].stop();
|
||||
this.$tours["guidedTour"]?.stop();
|
||||
this.$store.commit("core/setGuidedProperties", {tourStarted: false});
|
||||
},
|
||||
},
|
||||
@@ -79,7 +79,7 @@
|
||||
if (!this.guidedProperties.tourStarted
|
||||
&& localStorage.getItem("tourDoneOrSkip") !== "true"
|
||||
&& this.total === 0) {
|
||||
this.$tours["guidedTour"].start();
|
||||
this.$tours["guidedTour"]?.start();
|
||||
}
|
||||
}, 200)
|
||||
window.addEventListener("popstate", () => {
|
||||
|
||||
@@ -55,7 +55,7 @@
|
||||
handler: function (newValue) {
|
||||
if (newValue?.manuallyContinue) {
|
||||
setTimeout(() => {
|
||||
this.$tours["guidedTour"].nextStep();
|
||||
this.$tours["guidedTour"]?.nextStep();
|
||||
this.$store.commit("core/setGuidedProperties", {manuallyContinue: false});
|
||||
}, 500);
|
||||
}
|
||||
|
||||
@@ -6,7 +6,7 @@
|
||||
placement="left"
|
||||
:persistent="true"
|
||||
:title="`${$t('trigger details')}: ${trigger ? trigger.id : ''}`"
|
||||
width=""
|
||||
width="35em"
|
||||
transition=""
|
||||
:hide-after="0"
|
||||
>
|
||||
|
||||
@@ -91,12 +91,12 @@
|
||||
},
|
||||
methods: {
|
||||
onClick() {
|
||||
if (this.$tours["guidedTour"].isRunning.value) {
|
||||
this.$tours["guidedTour"].nextStep();
|
||||
if (this.$tours["guidedTour"]?.isRunning?.value) {
|
||||
this.$tours["guidedTour"]?.nextStep();
|
||||
this.$store.dispatch("api/events", {
|
||||
type: "ONBOARDING",
|
||||
onboarding: {
|
||||
step: this.$tours["guidedTour"].currentStep._value,
|
||||
step: this.$tours["guidedTour"]?.currentStep?._value,
|
||||
action: "next",
|
||||
template: this.guidedProperties.template
|
||||
},
|
||||
@@ -131,7 +131,7 @@
|
||||
},
|
||||
beforeClose(done){
|
||||
if(this.guidedProperties.tourStarted) return;
|
||||
|
||||
|
||||
this.reset();
|
||||
done()
|
||||
}
|
||||
|
||||
@@ -11,6 +11,9 @@
|
||||
<template v-if="scope.row.key === 'description'">
|
||||
<markdown :source="scope.row.value" />
|
||||
</template>
|
||||
<template v-else-if="scope.row.key === 'cron'">
|
||||
<cron :cron-expression="scope.row.value" />
|
||||
</template>
|
||||
<template v-else>
|
||||
<var-value :value="scope.row.value" :execution="execution" />
|
||||
</template>
|
||||
@@ -23,11 +26,13 @@
|
||||
import Utils from "../../utils/utils";
|
||||
import VarValue from "../executions/VarValue.vue";
|
||||
import Markdown from "../layout/Markdown.vue";
|
||||
import Cron from "../layout/Cron.vue";
|
||||
|
||||
export default {
|
||||
components: {
|
||||
VarValue,
|
||||
Markdown
|
||||
Markdown,
|
||||
Cron
|
||||
},
|
||||
props: {
|
||||
data: {
|
||||
|
||||
@@ -185,9 +185,9 @@
|
||||
padding: calc(2 * var(--spacer)) $spacer !important;
|
||||
font-family: $font-family-monospace;
|
||||
background-color: white;
|
||||
white-space: pre;
|
||||
white-space: normal;
|
||||
border-top: 1px solid var(--bs-gray-300);
|
||||
text-wrap: initial;
|
||||
text-wrap: wrap;
|
||||
|
||||
html.dark & {
|
||||
color: white;
|
||||
|
||||
@@ -38,7 +38,7 @@
|
||||
},
|
||||
computed: {
|
||||
values() {
|
||||
if (this.modelValue === undefined) {
|
||||
if (this.modelValue === undefined || (Array.isArray(this.modelValue) && this.modelValue.length === 0)) {
|
||||
return this.schema.default || [undefined];
|
||||
}
|
||||
|
||||
|
||||
@@ -188,6 +188,11 @@
|
||||
}
|
||||
},
|
||||
created() {
|
||||
// Auth but no permission at all or no permission to load execution stats
|
||||
if (this.user && (!this.user.hasAnyRole() || !this.user.hasAnyActionOnAnyNamespace(permission.EXECUTION, action.READ))) {
|
||||
this.$router.push({name:"errors/403"});
|
||||
return;
|
||||
}
|
||||
this.load();
|
||||
},
|
||||
watch: {
|
||||
@@ -239,8 +244,10 @@
|
||||
return _merge(base, queryFilter)
|
||||
},
|
||||
load() {
|
||||
this.loadStats();
|
||||
this.haveExecutions();
|
||||
if (this.user && this.user.hasAnyActionOnAnyNamespace(permission.EXECUTION, action.READ)) {
|
||||
this.loadStats();
|
||||
this.haveExecutions();
|
||||
}
|
||||
},
|
||||
haveExecutions() {
|
||||
let params = {
|
||||
|
||||
@@ -61,7 +61,6 @@
|
||||
<input
|
||||
ref="folderPicker"
|
||||
type="file"
|
||||
multiple
|
||||
webkitdirectory
|
||||
mozdirectory
|
||||
msdirectory
|
||||
@@ -77,7 +76,7 @@
|
||||
<template #dropdown>
|
||||
<el-dropdown-menu>
|
||||
<el-dropdown-item @click="$refs.filePicker.click()">
|
||||
{{ $t("namespace files.import.file") }}
|
||||
{{ $t("namespace files.import.files") }}
|
||||
</el-dropdown-item>
|
||||
<el-dropdown-item
|
||||
@click="$refs.folderPicker.click()"
|
||||
@@ -141,8 +140,8 @@
|
||||
</template>
|
||||
<template #default="{data, node}">
|
||||
<el-dropdown
|
||||
:ref="`dropdown__${data.fileName}`"
|
||||
@contextmenu.prevent.stop="toggleDropdown(`dropdown__${data.fileName}`)"
|
||||
:ref="`dropdown__${data.id}`"
|
||||
@contextmenu.prevent.stop="toggleDropdown(`dropdown__${data.id}`)"
|
||||
trigger="contextmenu"
|
||||
class="w-100"
|
||||
>
|
||||
@@ -385,7 +384,7 @@
|
||||
},
|
||||
computed: {
|
||||
...mapState({
|
||||
flows: (state) => state.flow.flows,
|
||||
flow: (state) => state.flow.flow,
|
||||
explorerVisible: (state) => state.editor.explorerVisible,
|
||||
}),
|
||||
folders() {
|
||||
@@ -720,7 +719,7 @@
|
||||
}
|
||||
|
||||
const {fileName, extension, content, leaf} = FILE;
|
||||
const NAME = `${fileName}.${extension}`;
|
||||
const NAME = `${fileName}${extension ? `.${extension}` : ""}`;
|
||||
const NEW = {
|
||||
id: Utils.uid(),
|
||||
fileName: NAME,
|
||||
@@ -765,17 +764,17 @@
|
||||
(function pushItemToFolder(basePath = "", array) {
|
||||
for (const item of array) {
|
||||
const folderPath = `${basePath}${item.fileName}`;
|
||||
|
||||
|
||||
if (folderPath === SELF.dialog.folder && Array.isArray(item.children)) {
|
||||
item.children = SELF.sorted([...item.children, NEW]);
|
||||
return true; // Return true if the folder is found and item is pushed
|
||||
}
|
||||
|
||||
|
||||
if (Array.isArray(item.children) && pushItemToFolder(`${folderPath}/`, item.children)) {
|
||||
return true; // Return true if the folder is found and item is pushed in recursive call
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
return false;
|
||||
})(undefined, this.items);
|
||||
}
|
||||
@@ -883,9 +882,9 @@
|
||||
},
|
||||
},
|
||||
watch: {
|
||||
flows: {
|
||||
flow: {
|
||||
handler(flow) {
|
||||
if (flow && flow.length) {
|
||||
if (flow) {
|
||||
this.changeOpenedTabs({
|
||||
action: "open",
|
||||
name: "Flow",
|
||||
@@ -948,21 +947,21 @@
|
||||
.empty {
|
||||
position: relative;
|
||||
top: 100px;
|
||||
text-align: center;
|
||||
text-align: center;
|
||||
color: white;
|
||||
|
||||
html.light & {
|
||||
color: $tertiary;
|
||||
}
|
||||
|
||||
|
||||
& img {
|
||||
margin-bottom: 2rem;
|
||||
margin-bottom: 2rem;
|
||||
}
|
||||
|
||||
& h3 {
|
||||
font-size: var(--font-size-lg);
|
||||
font-weight: 500;
|
||||
margin-bottom: .5rem;
|
||||
font-weight: 500;
|
||||
margin-bottom: .5rem;
|
||||
}
|
||||
|
||||
& p {
|
||||
|
||||
@@ -114,6 +114,8 @@
|
||||
},
|
||||
});
|
||||
|
||||
const isCurrentTabFlow = computed(() => currentTab?.value?.extension === undefined)
|
||||
|
||||
const flowErrors = computed(() => {
|
||||
const isFlow = currentTab?.value?.extension === undefined;
|
||||
|
||||
@@ -466,7 +468,7 @@
|
||||
editorViewTypes.SOURCE_TOPOLOGY,
|
||||
].includes(viewType.value)
|
||||
) {
|
||||
fetchGraph();
|
||||
if(!value.constraints) fetchGraph();
|
||||
}
|
||||
|
||||
if (validationDomElement.value && editorDomElement.value?.$el?.offsetWidth) {
|
||||
@@ -585,8 +587,10 @@
|
||||
timer.value = setTimeout(() => onEdit(event, isFlow), 500);
|
||||
};
|
||||
|
||||
const switchViewType = (event) => {
|
||||
persistViewType(event);
|
||||
const switchViewType = (event, shouldPersist = true) => {
|
||||
if(shouldPersist) persistViewType(event)
|
||||
else viewType.value = event
|
||||
|
||||
if (
|
||||
[editorViewTypes.TOPOLOGY, editorViewTypes.SOURCE_TOPOLOGY].includes(
|
||||
viewType.value
|
||||
@@ -639,7 +643,6 @@
|
||||
})
|
||||
.then(() => {
|
||||
overrideFlow.value = true;
|
||||
console.log("pop");
|
||||
return true;
|
||||
})
|
||||
.catch(() => {
|
||||
@@ -878,7 +881,13 @@
|
||||
return tab.name === currentTab.value.name;
|
||||
}
|
||||
|
||||
watch(currentTab, () => {
|
||||
watch(currentTab, (current, previous) => {
|
||||
const isCurrentFlow = current?.name === "Flow";
|
||||
const isPreviousFlow = previous?.name === "Flow";
|
||||
|
||||
if(isPreviousFlow) persistViewType(viewType.value);
|
||||
switchViewType(isCurrentFlow ? loadViewType() : editorViewTypes.SOURCE, false)
|
||||
|
||||
nextTick(() => {
|
||||
const activeTabElement = tabsScrollRef.value.wrapRef.querySelector(".tab-active");
|
||||
const rightMostCurrentTabPixel = activeTabElement.offsetLeft + activeTabElement.clientWidth;
|
||||
@@ -989,7 +998,7 @@
|
||||
@save="save"
|
||||
@execute="execute"
|
||||
v-model="flowYaml"
|
||||
schema-type="flow"
|
||||
:schema-type="isCurrentTabFlow? 'flow': undefined"
|
||||
:lang="currentTab?.extension === undefined ? 'yaml' : undefined"
|
||||
:extension="currentTab?.extension"
|
||||
@update:model-value="editorUpdate"
|
||||
|
||||
@@ -39,18 +39,26 @@
|
||||
@update:model-value="onChange"
|
||||
show-password
|
||||
/>
|
||||
<el-input-number
|
||||
v-if="input.type === 'INT'"
|
||||
v-model="inputs[input.id]"
|
||||
@update:model-value="onChange"
|
||||
:step="1"
|
||||
/>
|
||||
<el-input-number
|
||||
v-if="input.type === 'FLOAT'"
|
||||
v-model="inputs[input.id]"
|
||||
@update:model-value="onChange"
|
||||
:step="0.001"
|
||||
/>
|
||||
<span v-if="input.type === 'INT'">
|
||||
<el-input-number
|
||||
v-model="inputs[input.id]"
|
||||
@update:model-value="onChange"
|
||||
:min="input.min"
|
||||
:max="input.max && input.max >= (input.min || -Infinity) ? input.max : Infinity"
|
||||
:step="1"
|
||||
/>
|
||||
<div v-if="input.min || input.max" class="hint">{{ numberHint(input) }}</div>
|
||||
</span>
|
||||
<span v-if="input.type === 'FLOAT'">
|
||||
<el-input-number
|
||||
v-model="inputs[input.id]"
|
||||
@update:model-value="onChange"
|
||||
:min="input.min"
|
||||
:max="input.max && input.max >= (input.min || -Infinity) ? input.max : Infinity"
|
||||
:step="0.001"
|
||||
/>
|
||||
<div v-if="input.min || input.max" class="hint">{{ numberHint(input) }}</div>
|
||||
</span>
|
||||
<el-radio-group
|
||||
v-if="input.type === 'BOOLEAN'"
|
||||
v-model="inputs[input.id]"
|
||||
@@ -182,6 +190,18 @@
|
||||
this.inputs[input.id] = e.target.files[0];
|
||||
this.onChange();
|
||||
},
|
||||
numberHint(input){
|
||||
const {min, max} = input;
|
||||
|
||||
if (min !== undefined && max !== undefined) {
|
||||
if(min > max) return `Minimum value ${min} is larger than maximum value ${max}, so we've removed the upper limit.`;
|
||||
return `Minimum value is ${min}, maximum value is ${max}.`;
|
||||
} else if (min !== undefined) {
|
||||
return `Minimum value is ${min}.`;
|
||||
} else if (max !== undefined) {
|
||||
return `Maximum value is ${max}.`;
|
||||
} else return false;
|
||||
}
|
||||
},
|
||||
watch: {
|
||||
inputs: {
|
||||
@@ -199,5 +219,8 @@
|
||||
</script>
|
||||
|
||||
<style scoped lang="scss">
|
||||
|
||||
.hint {
|
||||
font-size: var(--font-size-xs);
|
||||
color: var(--bs-gray-700);
|
||||
}
|
||||
</style>
|
||||
@@ -16,6 +16,7 @@
|
||||
import JsonWorker from "monaco-editor/esm/vs/language/json/json.worker?worker";
|
||||
import {configureMonacoYaml} from "monaco-yaml";
|
||||
import {yamlSchemas} from "override/utils/yamlSchemas";
|
||||
import {editorViewTypes} from "../../utils/constants";
|
||||
import Utils from "../../utils/utils";
|
||||
import YamlUtils from "../../utils/yamlUtils";
|
||||
import uniqBy from "lodash/uniqBy";
|
||||
@@ -56,7 +57,8 @@
|
||||
...mapState({
|
||||
currentTab: (state) => state.editor.current,
|
||||
tabs: (state) => state.editor.tabs,
|
||||
flow: (state) => state.flow.flow
|
||||
flow: (state) => state.flow.flow,
|
||||
view: (state) => state.editor.view
|
||||
}),
|
||||
prefix() {
|
||||
return this.schemaType ? `${this.schemaType}-` : "";
|
||||
@@ -430,7 +432,8 @@
|
||||
id: subflowTask.flowId,
|
||||
revision: subflowTask.revision,
|
||||
source: false,
|
||||
store: false
|
||||
store: false,
|
||||
deleted: true
|
||||
}
|
||||
)).inputs?.map(input => input.id) ?? [];
|
||||
} catch (e) {
|
||||
@@ -631,6 +634,8 @@
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
setTimeout(() => monaco.editor.remeasureFonts(), 1)
|
||||
this.$emit("editorDidMount", this.editor);
|
||||
},
|
||||
async changeTab(pathOrName, valueSupplier, useModelCache = true) {
|
||||
@@ -672,6 +677,8 @@
|
||||
this.editor.focus();
|
||||
},
|
||||
destroy: function () {
|
||||
if(this.view === editorViewTypes.TOPOLOGY) return;
|
||||
|
||||
this.subflowAutocompletionProvider?.dispose();
|
||||
this.pebbleAutocompletion?.dispose();
|
||||
this.nestedFieldAutocompletionProvider?.dispose();
|
||||
|
||||
@@ -3,17 +3,17 @@
|
||||
<el-tooltip :content="$t('source')" transition="" :hide-after="0" :persistent="false" effect="light">
|
||||
<el-button :type="buttonType(editorViewTypes.SOURCE)" @click="switchView(editorViewTypes.SOURCE)" :icon="FileDocumentEditOutline" />
|
||||
</el-tooltip>
|
||||
<el-tooltip :content="$t('source and doc')" transition="" :hide-after="0" :persistent="false" effect="light">
|
||||
<el-button :type="buttonType(editorViewTypes.SOURCE_DOC)" @click="switchView(editorViewTypes.SOURCE_DOC)" :icon="BookOpenOutline" />
|
||||
<el-tooltip :content="!isFlow ? $t('flow_only') : $t('source and doc')" transition="" :hide-after="0" :persistent="false" effect="light">
|
||||
<el-button :disabled="!isFlow" :type="buttonType(editorViewTypes.SOURCE_DOC)" @click="switchView(editorViewTypes.SOURCE_DOC)" :icon="BookOpenOutline" />
|
||||
</el-tooltip>
|
||||
<el-tooltip :content="$t('source and topology')" transition="" :hide-after="0" :persistent="false" effect="light">
|
||||
<el-button :type="buttonType(editorViewTypes.SOURCE_TOPOLOGY)" @click="switchView(editorViewTypes.SOURCE_TOPOLOGY)" :icon="FileTableOutline" />
|
||||
<el-tooltip :content="!isFlow ? $t('flow_only') : $t('source and topology')" transition="" :hide-after="0" :persistent="false" effect="light">
|
||||
<el-button :disabled="!isFlow" :type="buttonType(editorViewTypes.SOURCE_TOPOLOGY)" @click="switchView(editorViewTypes.SOURCE_TOPOLOGY)" :icon="FileTableOutline" />
|
||||
</el-tooltip>
|
||||
<el-tooltip :content="$t('topology')" transition="" :hide-after="0" :persistent="false" effect="light">
|
||||
<el-button :type="buttonType(editorViewTypes.TOPOLOGY)" @click="switchView(editorViewTypes.TOPOLOGY)" :icon="FileTreeOutline" />
|
||||
<el-tooltip :content="!isFlow ? $t('flow_only') : $t('topology')" transition="" :hide-after="0" :persistent="false" effect="light">
|
||||
<el-button :disabled="!isFlow" :type="buttonType(editorViewTypes.TOPOLOGY)" @click="switchView(editorViewTypes.TOPOLOGY)" :icon="FileTreeOutline" />
|
||||
</el-tooltip>
|
||||
<el-tooltip :content="$t('source and blueprints')" transition="" :hide-after="0" :persistent="false" effect="light">
|
||||
<el-button :type="buttonType(editorViewTypes.SOURCE_BLUEPRINTS)" @click="switchView(editorViewTypes.SOURCE_BLUEPRINTS)" :icon="BallotOutline" />
|
||||
<el-tooltip :content="!isFlow ? $t('flow_only') : $t('source and blueprints')" transition="" :hide-after="0" :persistent="false" effect="light">
|
||||
<el-button :disabled="!isFlow" :type="buttonType(editorViewTypes.SOURCE_BLUEPRINTS)" @click="switchView(editorViewTypes.SOURCE_BLUEPRINTS)" :icon="BallotOutline" />
|
||||
</el-tooltip>
|
||||
</el-button-group>
|
||||
</template>
|
||||
@@ -28,6 +28,8 @@
|
||||
</script>
|
||||
|
||||
<script>
|
||||
import {mapState, mapMutations} from "vuex";
|
||||
|
||||
export default {
|
||||
props: {
|
||||
type: {
|
||||
@@ -36,8 +38,19 @@
|
||||
}
|
||||
},
|
||||
emits: ["switch-view"],
|
||||
computed: {
|
||||
...mapState({
|
||||
currentTab: (state) => state.editor.current
|
||||
}),
|
||||
isFlow(){
|
||||
return this.currentTab?.name === "Flow"
|
||||
}
|
||||
},
|
||||
methods: {
|
||||
...mapMutations("editor", ["changeView"]),
|
||||
|
||||
switchView(view) {
|
||||
this.changeView(view)
|
||||
this.$emit("switch-view", view)
|
||||
},
|
||||
buttonType(view) {
|
||||
|
||||
25
ui/src/components/layout/Cron.vue
Normal file
25
ui/src/components/layout/Cron.vue
Normal file
@@ -0,0 +1,25 @@
|
||||
<template>
|
||||
<span data-component="FILENAME_PLACEHOLDER">
|
||||
{{ humanReadableCron }}
|
||||
</span>
|
||||
</template>
|
||||
|
||||
<script>
|
||||
import Utils from "../../utils/utils.js";
|
||||
import cronstrue from "cronstrue";
|
||||
import "cronstrue/locales/fr";
|
||||
|
||||
export default {
|
||||
props: {
|
||||
cronExpression: {
|
||||
type: String,
|
||||
default: undefined
|
||||
}
|
||||
},
|
||||
computed: {
|
||||
humanReadableCron() {
|
||||
return cronstrue.toString(this.cronExpression, {locale: Utils.getLang()});
|
||||
}
|
||||
}
|
||||
}
|
||||
</script>
|
||||
@@ -48,9 +48,13 @@
|
||||
[]
|
||||
)
|
||||
.forEach(label => {
|
||||
const split = label.split(":");
|
||||
const separatorIndex = label.indexOf(":");
|
||||
|
||||
labels.set(split[0], split[1]);
|
||||
if (separatorIndex === -1) {
|
||||
return;
|
||||
}
|
||||
|
||||
labels.set(label.slice(0, separatorIndex), label.slice(separatorIndex + 1));
|
||||
})
|
||||
|
||||
return labels;
|
||||
|
||||
@@ -69,7 +69,7 @@
|
||||
<Slack class="align-middle" /> {{ $t("join community") }}
|
||||
</a>
|
||||
<a
|
||||
href="https://kestra.io/contact-us?utm_source=app&utm_content=top-nav-bar"
|
||||
href="https://kestra.io/demo?utm_source=app&utm_content=top-nav-bar"
|
||||
target="_blank"
|
||||
class="d-flex gap-2 el-dropdown-menu__item"
|
||||
>
|
||||
@@ -147,7 +147,7 @@
|
||||
localStorage.setItem("tourDoneOrSkip", undefined);
|
||||
this.$store.commit("core/setGuidedProperties", {tourStarted: false});
|
||||
|
||||
this.$tours["guidedTour"].start();
|
||||
this.$tours["guidedTour"]?.start();
|
||||
}
|
||||
}
|
||||
};
|
||||
|
||||
@@ -21,6 +21,8 @@
|
||||
<script>
|
||||
import {mapState} from "vuex";
|
||||
import _uniqBy from "lodash/uniqBy";
|
||||
import permission from "../../models/permission";
|
||||
import action from "../../models/action";
|
||||
|
||||
export default {
|
||||
props: {
|
||||
@@ -43,14 +45,17 @@
|
||||
},
|
||||
emits: ["update:modelValue"],
|
||||
created() {
|
||||
this.$store
|
||||
.dispatch("namespace/loadNamespacesForDatatype", {dataType: this.dataType})
|
||||
.then(() => {
|
||||
this.groupedNamespaces = this.groupNamespaces(this.datatypeNamespaces);
|
||||
});
|
||||
if (this.user && this.user.hasAnyActionOnAnyNamespace(permission.NAMESPACE, action.READ)) {
|
||||
this.$store
|
||||
.dispatch("namespace/loadNamespacesForDatatype", {dataType: this.dataType})
|
||||
.then(() => {
|
||||
this.groupedNamespaces = this.groupNamespaces(this.datatypeNamespaces);
|
||||
});
|
||||
}
|
||||
},
|
||||
computed: {
|
||||
...mapState("namespace", ["datatypeNamespaces"])
|
||||
...mapState("namespace", ["datatypeNamespaces"]),
|
||||
...mapState("auth", ["user"]),
|
||||
},
|
||||
data() {
|
||||
return {
|
||||
|
||||
@@ -18,6 +18,7 @@
|
||||
import imageDoc from "../../assets/onboarding/onboarding-docs-dark.svg"
|
||||
import imageProduct from "../../assets/onboarding/onboarding-product-dark.svg"
|
||||
import Markdown from "../layout/Markdown.vue";
|
||||
import Utils from "../../utils/utils.js";
|
||||
|
||||
export default {
|
||||
name: "OnboardingCard",
|
||||
@@ -50,7 +51,7 @@
|
||||
},
|
||||
computed: {
|
||||
lang() {
|
||||
const lang = localStorage.getItem("lang") || "en";
|
||||
const lang = Utils.getLang();
|
||||
if (lang === "fr") {
|
||||
return "_fr"
|
||||
}
|
||||
|
||||
@@ -5,7 +5,7 @@
|
||||
<Block :heading="$t('settings.blocks.configuration.label')">
|
||||
<template #content>
|
||||
<Row>
|
||||
<Column :label="$t('settings.blocks.localization.fields.language')">
|
||||
<Column :label="$t('settings.blocks.configuration.fields.language')">
|
||||
<el-select :model-value="lang" @update:model-value="onLang">
|
||||
<el-option
|
||||
v-for="item in langOptions"
|
||||
@@ -124,7 +124,7 @@
|
||||
</template>
|
||||
</Block>
|
||||
|
||||
<Block :heading="$t('settings.blocks.localization.label')">
|
||||
<Block :heading="$t('settings.blocks.localization.label')" :note="$t('settings.blocks.localization.note')">
|
||||
<template #content>
|
||||
<Row>
|
||||
<Column :label="$t('settings.blocks.localization.fields.time_zone')">
|
||||
@@ -246,7 +246,7 @@
|
||||
|
||||
this.defaultNamespace = localStorage.getItem("defaultNamespace") || "";
|
||||
this.defaultLogLevel = localStorage.getItem("defaultLogLevel") || "INFO";
|
||||
this.lang = localStorage.getItem("lang") || "en";
|
||||
this.lang = Utils.getLang();
|
||||
this.theme = localStorage.getItem("theme") || "light";
|
||||
this.editorTheme = localStorage.getItem("editorTheme") || (darkTheme ? "dark" : "vs");
|
||||
this.dateFormat = localStorage.getItem(DATE_FORMAT_STORAGE_KEY) || "llll";
|
||||
|
||||
@@ -1,14 +1,24 @@
|
||||
<template>
|
||||
<section>
|
||||
<h1 class="heading" v-text="heading" />
|
||||
<h1 class="heading">
|
||||
<el-popover v-if="note" :content="note" trigger="hover" :width="400" class="info">
|
||||
<template #reference>
|
||||
<InformationOutline />
|
||||
</template>
|
||||
</el-popover>
|
||||
<span>{{ heading }}</span>
|
||||
</h1>
|
||||
<slot name="content" />
|
||||
<el-divider v-if="!last" />
|
||||
</section>
|
||||
</template>
|
||||
|
||||
<script setup lang="ts">
|
||||
import InformationOutline from "vue-material-design-icons/InformationOutline.vue";
|
||||
|
||||
defineProps({
|
||||
heading: {type: String, required: true},
|
||||
note: {type: String, default: undefined},
|
||||
last: {type: Boolean, default: false},
|
||||
});
|
||||
</script>
|
||||
@@ -20,9 +30,16 @@ section {
|
||||
margin: calc($spacer * 2);
|
||||
|
||||
& > h1.heading {
|
||||
display: flex;
|
||||
align-items: center;
|
||||
margin-bottom: calc($spacer * 2);
|
||||
font-size: calc($font-size-base * 1.5);
|
||||
font-weight: 600;
|
||||
|
||||
& > span.el-tooltip__trigger {
|
||||
cursor: pointer;
|
||||
margin-right: calc($spacer / 2);
|
||||
}
|
||||
}
|
||||
}
|
||||
</style>
|
||||
|
||||
@@ -183,17 +183,17 @@ export default {
|
||||
}
|
||||
},
|
||||
save() {
|
||||
if (this.$tours["guidedTour"].isRunning.value && !this.guidedProperties.saveFlow) {
|
||||
if (this.$tours["guidedTour"]?.isRunning?.value && !this.guidedProperties.saveFlow) {
|
||||
this.$store.dispatch("api/events", {
|
||||
type: "ONBOARDING",
|
||||
onboarding: {
|
||||
step: this.$tours["guidedTour"].currentStep._value,
|
||||
step: this.$tours["guidedTour"]?.currentStep?._value,
|
||||
action: "next",
|
||||
template: this.guidedProperties.template
|
||||
},
|
||||
page: pageFromRoute(this.$router.currentRoute.value)
|
||||
});
|
||||
this.$tours["guidedTour"].nextStep();
|
||||
this.$tours["guidedTour"]?.nextStep();
|
||||
return;
|
||||
}
|
||||
|
||||
|
||||
@@ -1,5 +1,6 @@
|
||||
export default {
|
||||
FLOW: "FLOW",
|
||||
EXECUTION: "EXECUTION",
|
||||
TEMPLATE: "TEMPLATE"
|
||||
TEMPLATE: "TEMPLATE",
|
||||
NAMESPACE: "NAMESPACE"
|
||||
}
|
||||
|
||||
@@ -24,7 +24,6 @@ export default [
|
||||
{name: "root", path: "/", redirect: {name: "home"}},
|
||||
{name: "home", path: "/:tenant?/dashboard", component: Home},
|
||||
{name: "welcome", path: "/:tenant?/welcome", component: Welcome},
|
||||
{name: "home", path: "/:tenant?/dashboard", component: Home},
|
||||
|
||||
//Flows
|
||||
{name: "flows/list", path: "/:tenant?/flows", component: Flows},
|
||||
|
||||
@@ -23,6 +23,10 @@ class Me {
|
||||
hasAnyActionOnAnyNamespace(permission, action) {
|
||||
return true;
|
||||
}
|
||||
|
||||
hasAnyRole() {
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
export default {
|
||||
|
||||
@@ -6,6 +6,7 @@ export default {
|
||||
explorerWidth: 20,
|
||||
current: undefined,
|
||||
tabs: [],
|
||||
view: undefined,
|
||||
},
|
||||
mutations: {
|
||||
updateOnboarding(state) {
|
||||
@@ -84,5 +85,12 @@ export default {
|
||||
state.tabs = [state.tabs[0]];
|
||||
}
|
||||
},
|
||||
closeAllTabs(state) {
|
||||
state.tabs = [];
|
||||
state.current = undefined
|
||||
},
|
||||
changeView(state, view) {
|
||||
state.view = view;
|
||||
},
|
||||
},
|
||||
};
|
||||
|
||||
@@ -205,7 +205,19 @@ export default {
|
||||
return this.$http.get(`${apiUrl(this)}/executions/${options.executionId}/file/preview`, {
|
||||
params: options
|
||||
}).then(response => {
|
||||
commit("setFilePreview", response.data)
|
||||
let data = {...response.data}
|
||||
|
||||
// WORKAROUND, related to https://github.com/kestra-io/plugin-aws/issues/456
|
||||
if(data.extension === "ion") {
|
||||
const notObjects = data.content.some(e => typeof e !== "object");
|
||||
|
||||
if(notObjects) {
|
||||
const content = data.content.length === 1 ? data.content[0] : data.content.join("\n");
|
||||
data = {...data, type: "TEXT", content}
|
||||
}
|
||||
}
|
||||
|
||||
commit("setFilePreview", data)
|
||||
})
|
||||
},
|
||||
setLabels(_, options) {
|
||||
|
||||
@@ -37,7 +37,7 @@ export default {
|
||||
}).then(response => {
|
||||
commit("setFlows", response.data.results)
|
||||
commit("setTotal", response.data.total)
|
||||
commit("setOverallTotal", response.data.total)
|
||||
commit("setOverallTotal", response.data.results.filter(f => f.namespace !== "tutorial").length)
|
||||
|
||||
return response.data;
|
||||
})
|
||||
|
||||
@@ -1,7 +1,9 @@
|
||||
import Utils from "../utils/utils";
|
||||
import {apiUrl} from "override/utils/route";
|
||||
|
||||
const BASE = (namespace) => `${apiUrl(this)}/namespaces/${namespace}`;
|
||||
function base(namespace) {
|
||||
return `${apiUrl(this)}/namespaces/${namespace}`;
|
||||
}
|
||||
const HEADERS = {headers: {"Content-Type": "multipart/form-data"}};
|
||||
|
||||
const slashPrefix = (path) => (path.startsWith("/") ? path : `/${path}`);
|
||||
@@ -15,13 +17,13 @@ export default {
|
||||
actions: {
|
||||
// Create a directory
|
||||
async createDirectory(_, payload) {
|
||||
const URL = `${BASE(payload.namespace)}/files/directory?path=${slashPrefix(payload.path)}`;
|
||||
const URL = `${base.call(this, payload.namespace)}/files/directory?path=${slashPrefix(payload.path)}`;
|
||||
await this.$http.post(URL);
|
||||
},
|
||||
|
||||
// List directory content
|
||||
async readDirectory(_, payload) {
|
||||
const URL = `${BASE(payload.namespace)}/files/directory${payload.path ? `?path=${slashPrefix(safePath(payload.path))}` : ""}`;
|
||||
const URL = `${base.call(this, payload.namespace)}/files/directory${payload.path ? `?path=${slashPrefix(safePath(payload.path))}` : ""}`;
|
||||
const request = await this.$http.get(URL);
|
||||
|
||||
return request.data ?? [];
|
||||
@@ -33,21 +35,21 @@ export default {
|
||||
const BLOB = new Blob([payload.content], {type: "text/plain"});
|
||||
DATA.append("fileContent", BLOB);
|
||||
|
||||
const URL = `${BASE(payload.namespace)}/files?path=${slashPrefix(payload.path)}`;
|
||||
const URL = `${base.call(this, payload.namespace)}/files?path=${slashPrefix(payload.path)}`;
|
||||
await this.$http.post(URL, DATA, HEADERS);
|
||||
},
|
||||
|
||||
// Get namespace file content
|
||||
async readFile(_, payload) {
|
||||
const URL = `${BASE(payload.namespace)}/files?path=${slashPrefix(safePath(payload.path))}`;
|
||||
const request = await this.$http.get(URL);
|
||||
const URL = `${base.call(this, payload.namespace)}/files?path=${slashPrefix(safePath(payload.path))}`;
|
||||
const request = await this.$http.get(URL, {transformResponse: response => response, responseType: "json"})
|
||||
|
||||
return request.data ?? [];
|
||||
},
|
||||
|
||||
// Search for namespace files
|
||||
async searchFiles(_, payload) {
|
||||
const URL = `${BASE(payload.namespace)}/files/search?q=${payload.query}`;
|
||||
const URL = `${base.call(this, payload.namespace)}/files/search?q=${payload.query}`;
|
||||
const request = await this.$http.get(URL);
|
||||
|
||||
return request.data ?? [];
|
||||
@@ -59,31 +61,31 @@ export default {
|
||||
const BLOB = new Blob([payload.content], {type: "text/plain"});
|
||||
DATA.append("fileContent", BLOB);
|
||||
|
||||
const URL = `${BASE(payload.namespace)}/files?path=${slashPrefix(safePath(payload.path))}`;
|
||||
const URL = `${base.call(this, payload.namespace)}/files?path=${slashPrefix(safePath(payload.path))}`;
|
||||
await this.$http.post(URL, DATA, HEADERS);
|
||||
},
|
||||
|
||||
// Move a file or directory
|
||||
async moveFileDirectory(_, payload) {
|
||||
const URL = `${BASE(payload.namespace)}/files?from=${slashPrefix(payload.old)}&to=${slashPrefix(payload.new)}`;
|
||||
const URL = `${base.call(this, payload.namespace)}/files?from=${slashPrefix(payload.old)}&to=${slashPrefix(payload.new)}`;
|
||||
await this.$http.put(URL);
|
||||
},
|
||||
|
||||
// Rename a file or directory
|
||||
async renameFileDirectory(_, payload) {
|
||||
const URL = `${BASE(payload.namespace)}/files?from=${slashPrefix(payload.old)}&to=${slashPrefix(payload.new)}`;
|
||||
const URL = `${base.call(this, payload.namespace)}/files?from=${slashPrefix(payload.old)}&to=${slashPrefix(payload.new)}`;
|
||||
await this.$http.put(URL);
|
||||
},
|
||||
|
||||
// Delete a file or directory
|
||||
async deleteFileDirectory(_, payload) {
|
||||
const URL = `${BASE(payload.namespace)}/files?path=${slashPrefix(payload.path)}`;
|
||||
const URL = `${base.call(this, payload.namespace)}/files?path=${slashPrefix(payload.path)}`;
|
||||
await this.$http.delete(URL);
|
||||
},
|
||||
|
||||
// Export namespace files as a ZIP
|
||||
async exportFileDirectory(_, payload) {
|
||||
const URL = `${BASE(payload.namespace)}/files/export`;
|
||||
const URL = `${base.call(this, payload.namespace)}/files/export`;
|
||||
const request = await this.$http.get(URL);
|
||||
|
||||
const name = payload.namespace + "_files.zip";
|
||||
|
||||
@@ -308,10 +308,19 @@
|
||||
"errors": {
|
||||
"404": {
|
||||
"title": "Page not found",
|
||||
"content": "The requested URL was not found on this server. <span class=\"text-muted\">That’s all we know.</span>",
|
||||
"content": "The requested URL was not found on this server.<br />That’s all we know.",
|
||||
"flow or execution": "The flow or execution you are looking for does not exist."
|
||||
},
|
||||
"401": {
|
||||
"title": "Unauthorized",
|
||||
"content": "You need to be authenticated to access this page."
|
||||
},
|
||||
"403": {
|
||||
"title": "Access denied",
|
||||
"content": "You don't have the required permissions to access this page."
|
||||
}
|
||||
},
|
||||
"back_to_dashboard": "Back to dashboard",
|
||||
"copy logs": "Copy logs",
|
||||
"download logs": "Download logs",
|
||||
"delete logs": "Delete logs",
|
||||
@@ -546,7 +555,7 @@
|
||||
"environment color setting": "Environment color",
|
||||
"slack support": "Ask any question via Slack",
|
||||
"join community": "Join the Community",
|
||||
"reach us": "Reach out to us",
|
||||
"reach us": "Talk to us",
|
||||
"new version": "New version {version} available!",
|
||||
"error detected": "Error(s) detected",
|
||||
"warning detected": "Warning(s) detected",
|
||||
@@ -629,7 +638,7 @@
|
||||
},
|
||||
"import": {
|
||||
"import": "Import",
|
||||
"file": "Import file",
|
||||
"files": "Import files",
|
||||
"folder": "Import folder",
|
||||
"success": "File(s) successfully imported",
|
||||
"error": "Error(s) occurred while importing the file(s)"
|
||||
@@ -709,6 +718,7 @@
|
||||
"configuration": {
|
||||
"label": "Main Configuration",
|
||||
"fields": {
|
||||
"language": "Language",
|
||||
"default_namespace": "Default Namespace",
|
||||
"log_level": "Default Log Level",
|
||||
"log_display": "Default Log Display",
|
||||
@@ -729,8 +739,8 @@
|
||||
},
|
||||
"localization": {
|
||||
"label": "Date and Time Settings",
|
||||
"note": "Note that this setting is used for displaying date and time properties in the UI. To schedule your flows in a timezone different than UTC, make sure to set the timezone property on the Schedule trigger in your flow code or your plugin defaults.",
|
||||
"fields": {
|
||||
"language": "Language",
|
||||
"time_zone": "Time Zone",
|
||||
"date_format": "Date Format"
|
||||
}
|
||||
@@ -793,6 +803,7 @@
|
||||
"ee-tooltip": {
|
||||
"features-blocked": "This feature requires Enterprise Edition.",
|
||||
"button": "Talk to us"
|
||||
}
|
||||
},
|
||||
"flow_only": "Only available on Flow tab."
|
||||
}
|
||||
}
|
||||
@@ -297,10 +297,19 @@
|
||||
"errors": {
|
||||
"404": {
|
||||
"title": "Page introuvable",
|
||||
"content": "L'URL demandé est introuvable sur ce serveur. <span class=\"text-muted\">C'est tout ce que nous savons.</span>",
|
||||
"content": "L'URL demandée n'a pas été trouvée sur ce serveur.<br />C'est tout ce que nous savons.",
|
||||
"flow or execution": "Le flow ou l'exécution demandé est introuvable."
|
||||
},
|
||||
"401": {
|
||||
"title": "Non authentifié",
|
||||
"content": "Vous devez être authentifié pour accéder à cette page."
|
||||
},
|
||||
"403": {
|
||||
"title": "Accès refusé",
|
||||
"content": "Vous n'avez pas les permissions suffisantes pour accéder à cette page."
|
||||
}
|
||||
},
|
||||
"back_to_dashboard": "Retour au tableau de bord",
|
||||
"copy logs": "Copier les logs",
|
||||
"download logs": "Télécharger les logs",
|
||||
"delete logs": "Supprimer les logs",
|
||||
@@ -601,7 +610,7 @@
|
||||
},
|
||||
"import": {
|
||||
"import": "Importer",
|
||||
"file": "Importer un fichier",
|
||||
"files": "Importer des fichiers",
|
||||
"folder": "Importer un dossier",
|
||||
"success": "Fichier(s) importé(s) avec succès",
|
||||
"error": "Des erreurs se sont produites lors de l'importation du(des) fichier(s)"
|
||||
@@ -681,6 +690,7 @@
|
||||
"configuration": {
|
||||
"label": "Configuration Principale",
|
||||
"fields": {
|
||||
"language": "Langue",
|
||||
"default_namespace": "Espace de noms par défaut",
|
||||
"log_level": "Niveau d'affichage des journaux par défaut",
|
||||
"log_display": "Affichage des journaux par défaut",
|
||||
@@ -701,8 +711,8 @@
|
||||
},
|
||||
"localization": {
|
||||
"label": "Paramètres de Date et d'Heure",
|
||||
"note": "Remarque ce paramètre est utilisé pour afficher les propriétés de date et d'heure dans l'interface utilisateur. Pour planifier vos flux dans un fuseau horaire différent de l'UTC, assurez-vous de définir la propriété de fuseau horaire sur le déclencheur de planification dans le code de votre",
|
||||
"fields": {
|
||||
"language": "Langue",
|
||||
"time_zone": "Fuseau Horaire",
|
||||
"date_format": "Format de Date"
|
||||
}
|
||||
@@ -765,6 +775,7 @@
|
||||
"ee-tooltip": {
|
||||
"features-blocked": "Cette fonctionnalité nécessite l'édition Enterprise.",
|
||||
"button": "Contactez-nous"
|
||||
}
|
||||
},
|
||||
"flow_only": "Disponible uniquement sur l'onglet Flow."
|
||||
}
|
||||
}
|
||||
@@ -12,7 +12,7 @@ export default {
|
||||
return Utils.humanDuration(value, options);
|
||||
},
|
||||
humanizeNumber: (value) => {
|
||||
return parseInt(value).toLocaleString(localStorage.getItem("lang") || "en")
|
||||
return parseInt(value).toLocaleString(Utils.getLang());
|
||||
},
|
||||
cap: value => value ? value.toString().capitalize() : "",
|
||||
lower: value => value ? value.toString().toLowerCase() : "",
|
||||
|
||||
@@ -48,6 +48,7 @@ import TaskSubflowNamespace from "../components/flows/tasks/TaskSubflowNamespace
|
||||
import TaskSubflowId from "../components/flows/tasks/TaskSubflowId.vue";
|
||||
import TaskSubflowInputs from "../components/flows/tasks/TaskSubflowInputs.vue";
|
||||
import LeftMenuLink from "../components/LeftMenuLink.vue";
|
||||
import Utils from "./utils";
|
||||
|
||||
export default (app, routes, stores, translations) => {
|
||||
// charts
|
||||
@@ -101,7 +102,7 @@ export default (app, routes, stores, translations) => {
|
||||
|
||||
|
||||
// l18n
|
||||
let locale = localStorage.getItem("lang") || "en";
|
||||
let locale = Utils.getLang();
|
||||
|
||||
let i18n = createI18n({
|
||||
locale: locale,
|
||||
|
||||
@@ -4,16 +4,37 @@ export default class Inputs {
|
||||
static normalize(type, value) {
|
||||
let res = value;
|
||||
|
||||
if (value === null || value === undefined) {
|
||||
res = undefined;
|
||||
} else if (type === "DATE" || type === "DATETIME") {
|
||||
res = moment(res).toISOString()
|
||||
} else if (type === "DURATION" || type === "TIME") {
|
||||
res = moment().startOf("day").add(res, "seconds").toString()
|
||||
} else if (type === "ARRAY" || type === "MULTISELECT" || type === "JSON") {
|
||||
res = JSON.stringify(res).toString();
|
||||
} else if (type === "BOOLEAN" && type === undefined){
|
||||
res = "undefined";
|
||||
} else if (type === "STRING" && Array.isArray(res)){
|
||||
res = res.toString();
|
||||
}
|
||||
return res;
|
||||
}
|
||||
|
||||
static normalizeForComponents(type, value) {
|
||||
let res = value;
|
||||
|
||||
if (value === null) {
|
||||
res = undefined;
|
||||
} else if (type === "DATE" || type === "DATETIME") {
|
||||
res = moment(res).toISOString()
|
||||
} else if (type === "DURATION" || type === "TIME") {
|
||||
res = moment().startOf("day").add(res, "seconds").toString()
|
||||
} else if (type === "JSON" || type === "ARRAY") {
|
||||
res = JSON.stringify(res).toString()
|
||||
} else if (type === "ARRAY") {
|
||||
res = JSON.stringify(res).toString();
|
||||
} else if (type === "BOOLEAN" && type === undefined){
|
||||
res = "undefined";
|
||||
} else if (type === "STRING" && Array.isArray(res)){
|
||||
res = res.toString();
|
||||
}
|
||||
return res;
|
||||
}
|
||||
|
||||
@@ -19,9 +19,9 @@ export const inputsToFormDate = (submitor, inputsList, values) => {
|
||||
const inputValue = values[inputName];
|
||||
if (inputValue !== undefined) {
|
||||
if (input.type === "DATETIME") {
|
||||
formData.append(inputName, submitor.$moment(inputValue).toISOString());
|
||||
if(inputValue) formData.append(inputName, submitor.$moment(inputValue).toISOString());
|
||||
} else if (input.type === "DATE") {
|
||||
formData.append(inputName, submitor.$moment(inputValue).format("YYYY-MM-DD"));
|
||||
if(inputValue) formData.append(inputName, submitor.$moment(inputValue).format("YYYY-MM-DD"));
|
||||
} else if (input.type === "TIME") {
|
||||
formData.append(inputName, submitor.$moment(inputValue).format("hh:mm:ss"));
|
||||
} else if (input.type === "DURATION") {
|
||||
@@ -84,7 +84,7 @@ export const executeTask = (submitor, flow, values, options) => {
|
||||
}
|
||||
}
|
||||
|
||||
if(options.nextStep) submitor.$tours["guidedTour"].nextStep();
|
||||
if(options.nextStep) submitor.$tours["guidedTour"]?.nextStep();
|
||||
|
||||
return response.data;
|
||||
})
|
||||
|
||||
@@ -120,7 +120,7 @@ export default class Utils {
|
||||
static humanDuration(value, options) {
|
||||
options = options || {maxDecimalPoints: 2};
|
||||
options.spacer = "";
|
||||
options.language = localStorage.getItem("lang") || "en";
|
||||
options.language = Utils.getLang();
|
||||
options.languages = humanizeDurationLanguages;
|
||||
options.largest = 2;
|
||||
|
||||
@@ -187,6 +187,10 @@ export default class Utils {
|
||||
return localStorage.getItem("theme") || "light";
|
||||
}
|
||||
|
||||
static getLang() {
|
||||
return localStorage.getItem("lang") || "en";
|
||||
}
|
||||
|
||||
static splitFirst(str, separator){
|
||||
return str.split(separator).slice(1).join(separator);
|
||||
}
|
||||
|
||||
Some files were not shown because too many files have changed in this diff Show More
Reference in New Issue
Block a user