Package io.kestra.plugin.graalvm

Class RunContextProxy

java.lang.Object
io.kestra.core.runners.RunContext
io.kestra.plugin.graalvm.RunContextProxy
All Implemented Interfaces:
io.kestra.core.models.property.PropertyContext
public class RunContextProxy extends io.kestra.core.runners.RunContext

  • Constructor Details

    • RunContextProxy

      public RunContextProxy(io.kestra.core.runners.RunContext delegate)

  • Method Details

    • getTriggerExecutionId

      public String getTriggerExecutionId()
      Specified by:
      getTriggerExecutionId in class io.kestra.core.runners.RunContext

    • getVariables

      public Map<String,Object> getVariables()
      Specified by:
      getVariables in class io.kestra.core.runners.RunContext

    • getSecretInputs

      public List<String> getSecretInputs()
      Specified by:
      getSecretInputs in class io.kestra.core.runners.RunContext

    • getTraceParent

      public String getTraceParent()
      Specified by:
      getTraceParent in class io.kestra.core.runners.RunContext

    • setTraceParent

      public void setTraceParent(String traceParent)
      Specified by:
      setTraceParent in class io.kestra.core.runners.RunContext

    • render

      public String render(String inline) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      render in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • renderTyped

      public Object renderTyped(String inline) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      renderTyped in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • render

      public String render(String inline, Map<String,Object> variables) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      render in interface io.kestra.core.models.property.PropertyContext
      Specified by:
      render in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • render

      public <T> io.kestra.core.runners.RunContextProperty<T> render(io.kestra.core.models.property.Property<T> inline)
      Specified by:
      render in class io.kestra.core.runners.RunContext

    • render

      public List<String> render(List<String> inline) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      render in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • render

      public List<String> render(List<String> inline, Map<String,Object> variables) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      render in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • render

      public Set<String> render(Set<String> inline) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      render in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • render

      public Set<String> render(Set<String> inline, Map<String,Object> variables) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      render in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • render

      public Map<String,Object> render(Map<String,Object> inline) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      render in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • render

      public Map<String,Object> render(Map<String,Object> inline, Map<String,Object> variables) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      render in interface io.kestra.core.models.property.PropertyContext
      Specified by:
      render in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • renderMap

      public Map<String,String> renderMap(Map<String,String> inline) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      renderMap in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • renderMap

      public Map<String,String> renderMap(Map<String,String> inline, Map<String,Object> variables) throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      renderMap in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • validate

      public <T> void validate(T bean)
      Specified by:
      validate in class io.kestra.core.runners.RunContext

    • decrypt

      public String decrypt(String encrypted) throws GeneralSecurityException
      Specified by:
      decrypt in class io.kestra.core.runners.RunContext
      Throws:
      GeneralSecurityException

    • encrypt

      public String encrypt(String plaintext) throws GeneralSecurityException
      Specified by:
      encrypt in class io.kestra.core.runners.RunContext
      Throws:
      GeneralSecurityException

    • logger

      public org.slf4j.Logger logger()
      Specified by:
      logger in class io.kestra.core.runners.RunContext

    • logFileURI

      public URI logFileURI()
      Specified by:
      logFileURI in class io.kestra.core.runners.RunContext

    • getStorageOutputPrefix

      public URI getStorageOutputPrefix()
      Specified by:
      getStorageOutputPrefix in class io.kestra.core.runners.RunContext

    • storage

      public io.kestra.core.storages.Storage storage()
      Specified by:
      storage in class io.kestra.core.runners.RunContext

    • metrics

      public List<io.kestra.core.models.executions.AbstractMetricEntry<?>> metrics()
      Specified by:
      metrics in class io.kestra.core.runners.RunContext

    • metric

      public <T> io.kestra.core.runners.RunContext metric(io.kestra.core.models.executions.AbstractMetricEntry<T> metricEntry)
      Specified by:
      metric in class io.kestra.core.runners.RunContext

    • dynamicWorkerResult

      public void dynamicWorkerResult(List<io.kestra.core.runners.WorkerTaskResult> workerTaskResults)
      Specified by:
      dynamicWorkerResult in class io.kestra.core.runners.RunContext

    • dynamicWorkerResults

      public List<io.kestra.core.runners.WorkerTaskResult> dynamicWorkerResults()
      Specified by:
      dynamicWorkerResults in class io.kestra.core.runners.RunContext

    • workingDir

      public io.kestra.core.runners.WorkingDir workingDir()
      Specified by:
      workingDir in class io.kestra.core.runners.RunContext

    • cleanup

      public void cleanup()
      Specified by:
      cleanup in class io.kestra.core.runners.RunContext

    • tenantId

      public String tenantId()
      Specified by:
      tenantId in class io.kestra.core.runners.RunContext

    • taskRunInfo

      public io.kestra.core.runners.RunContext.TaskRunInfo taskRunInfo()
      Specified by:
      taskRunInfo in class io.kestra.core.runners.RunContext

    • flowInfo

      public io.kestra.core.runners.RunContext.FlowInfo flowInfo()
      Specified by:
      flowInfo in class io.kestra.core.runners.RunContext

    • pluginConfiguration

      public <T> Optional<T> pluginConfiguration(String name)
      Specified by:
      pluginConfiguration in class io.kestra.core.runners.RunContext

    • pluginConfigurations

      public Map<String,Object> pluginConfigurations()
      Specified by:
      pluginConfigurations in class io.kestra.core.runners.RunContext

    • version

      public String version()
      Specified by:
      version in class io.kestra.core.runners.RunContext

    • namespaceKv

      public io.kestra.core.storages.kv.KVStore namespaceKv(String namespace)
      Specified by:
      namespaceKv in class io.kestra.core.runners.RunContext

    • localPath

      public io.kestra.core.runners.LocalPath localPath()
      Specified by:
      localPath in class io.kestra.core.runners.RunContext

    • isInitialized

      public boolean isInitialized()
      Specified by:
      isInitialized in class io.kestra.core.runners.RunContext

    • acl

      public io.kestra.core.runners.AclChecker acl()
      Specified by:
      acl in class io.kestra.core.runners.RunContext

    • assets

      public io.kestra.core.runners.AssetEmitter assets() throws io.kestra.core.exceptions.IllegalVariableEvaluationException
      Specified by:
      assets in class io.kestra.core.runners.RunContext
      Throws:
      io.kestra.core.exceptions.IllegalVariableEvaluationException

    • cloneForPlugin

      public io.kestra.core.runners.RunContext cloneForPlugin(io.kestra.core.models.Plugin plugin)
      Specified by:
      cloneForPlugin in class io.kestra.core.runners.RunContext

    • inputAndOutput

      public io.kestra.core.runners.InputAndOutput inputAndOutput()
      Specified by:
      inputAndOutput in class io.kestra.core.runners.RunContext

    • sdk

      public io.kestra.core.runners.SDK sdk()
      Specified by:
      sdk in class io.kestra.core.runners.RunContext