Skip to content

Commit

Permalink
feat(core): remove Flow and Worker task and use aliases
Browse files Browse the repository at this point in the history
  • Loading branch information
loicmathieu committed May 15, 2024
1 parent a9f221d commit 5cee7fa
Show file tree
Hide file tree
Showing 7 changed files with 11 additions and 90 deletions.
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
@PluginSubGroup(categories = { PluginSubGroup.PluginCategory.CORE })
package io.kestra.plugin.core.condition;

import io.kestra.core.models.annotations.PluginSubGroup;
39 changes: 0 additions & 39 deletions core/src/main/java/io/kestra/plugin/core/flow/Flow.java

This file was deleted.

2 changes: 1 addition & 1 deletion core/src/main/java/io/kestra/plugin/core/flow/Subflow.java
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@
}
)
},
aliases = "io.kestra.core.tasks.flows.Subflow"
aliases = {"io.kestra.core.tasks.flows.Subflow", "io.kestra.core.tasks.flows.Flow"}
)
public class Subflow extends Task implements ExecutableTask<Subflow.Output>, ChildFlowInterface {

Expand Down
48 changes: 0 additions & 48 deletions core/src/main/java/io/kestra/plugin/core/flow/Worker.java

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -191,7 +191,7 @@ with open('output.json', 'w') as output_file:
console.log(colors.red("Hello"));"""
)
},
aliases = "io.kestra.core.tasks.flows.WorkingDirectory"
aliases = {"io.kestra.core.tasks.flows.WorkingDirectory", "io.kestra.core.tasks.flows.Worker"}
)
@WorkingDirectoryTaskValidation
public class WorkingDirectory extends Sequential implements NamespaceFilesInterface, InputFilesInterface, OutputFilesInterface {
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,4 @@
@PluginSubGroup(categories = { PluginSubGroup.PluginCategory.CORE})
package io.kestra.plugin.core.runner;

import io.kestra.core.models.annotations.PluginSubGroup;
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
@PluginSubGroup(categories = { PluginSubGroup.PluginCategory.STORAGE, PluginSubGroup.PluginCategory.CORE})
@PluginSubGroup(categories = { PluginSubGroup.PluginCategory.CORE})
package io.kestra.plugin.core.trigger;

import io.kestra.core.models.annotations.PluginSubGroup;

0 comments on commit 5cee7fa

Please sign in to comment.