Package dev.frostlake.metastore.model

Class Task

java.lang.Object
dev.frostlake.metastore.model.Task
public class Task extends Object
Represents a Snowflake Task - Scheduled SQL execution

  • Constructor Details

  • Method Details

    • addPredecessor

      public void addPredecessor(String taskName)

    • recordExecution

      public void recordExecution(TaskExecution execution)

    • getLastReturnValue

      public String getLastReturnValue()

    • setLastReturnValue

      public void setLastReturnValue(String lastReturnValue)

    • getId

      public String getId()
      The opaque task identifier live reports as SHOW TASKS' id.

    • setId

      public void setId(String id)
      Restore the identity a snapshot recorded, so it survives a reload as live's does.

    • getExplicitParameters

      public Set<String> getExplicitParameters()
      The parameter names set on this task, for the snapshot writer.

    • getCreatedByUser

      public String getCreatedByUser()
      The user who ran the CREATE TASK, which live reports as created_by_user.

    • setCreatedByUser

      public void setCreatedByUser(String createdByUser)

    • markParameterSet

      public void markParameterSet(String parameterName)
      Record that parameterName was given on the task itself rather than left at its default.

    • isParameterSetOnTask

      public boolean isParameterSetOnTask(String parameterName)
      Whether the task set this parameter itself — the difference between a TASK level and a blank one.

    • getName

      public String getName()

    • getOwner

      public String getOwner()

    • setOwner

      public void setOwner(String owner)

    • getSchedule

      public String getSchedule()

    • getScheduleType

      public ScheduleType getScheduleType()

    • getSqlStatement

      public String getSqlStatement()

    • getWarehouse

      public String getWarehouse()

    • getPredecessors

      public List<String> getPredecessors()

    • getCreatedAt

      public LocalDateTime getCreatedAt()

    • getState

      public TaskState getState()

    • setState

      public void setState(TaskState state)

    • getLastRunTime

      public LocalDateTime getLastRunTime()

    • setLastRunTime

      public void setLastRunTime(LocalDateTime lastRunTime)

    • getNextRunTime

      public LocalDateTime getNextRunTime()

    • setNextRunTime

      public void setNextRunTime(LocalDateTime nextRunTime)

    • getExecutionHistory

      public List<TaskExecution> getExecutionHistory()

    • getSuccessCount

      public int getSuccessCount()

    • getFailureCount

      public int getFailureCount()

    • isActive

      public boolean isActive()

    • getComment

      public String getComment()

    • setComment

      public void setComment(String comment)

    • getCondition

      public String getCondition()

    • setCondition

      public void setCondition(String condition)

    • setSchedule

      public void setSchedule(String schedule)

    • setScheduleType

      public void setScheduleType(ScheduleType scheduleType)

    • setSqlStatement

      public void setSqlStatement(String sqlStatement)

    • setWarehouse

      public void setWarehouse(String warehouse)

    • getSuspendTaskAfterNumFailures

      public int getSuspendTaskAfterNumFailures()

    • setSuspendTaskAfterNumFailures

      public void setSuspendTaskAfterNumFailures(int v)

    • getTaskAutoRetryAttempts

      public int getTaskAutoRetryAttempts()

    • setTaskAutoRetryAttempts

      public void setTaskAutoRetryAttempts(int v)

    • getUserTaskManagedInitialWarehouseSize

      public String getUserTaskManagedInitialWarehouseSize()

    • setUserTaskManagedInitialWarehouseSize

      public void setUserTaskManagedInitialWarehouseSize(String v)

    • getServerlessTaskMaxStatementSize

      public String getServerlessTaskMaxStatementSize()

    • setServerlessTaskMaxStatementSize

      public void setServerlessTaskMaxStatementSize(String v)

    • getTargetCompletionInterval

      public String getTargetCompletionInterval()

    • setTargetCompletionInterval

      public void setTargetCompletionInterval(String v)

    • getErrorIntegration

      public String getErrorIntegration()

    • setErrorIntegration

      public void setErrorIntegration(String v)

    • getUserTaskMinimumTriggerIntervalInSeconds

      public int getUserTaskMinimumTriggerIntervalInSeconds()

    • setUserTaskMinimumTriggerIntervalInSeconds

      public void setUserTaskMinimumTriggerIntervalInSeconds(int v)

    • isAllowOverlappingExecution

      public boolean isAllowOverlappingExecution()

    • setAllowOverlappingExecution

      public void setAllowOverlappingExecution(boolean allowOverlappingExecution)

    • getUserTaskTimeoutMs

      public long getUserTaskTimeoutMs()

    • setUserTaskTimeoutMs

      public void setUserTaskTimeoutMs(long userTaskTimeoutMs)