WorkerTaskManager (Snowflake Native SDK for Connectors - Java API Reference (2.2.0))

java.lang.Object
- com.snowflake.connectors.taskreactor.worker.WorkerTaskManager

public class WorkerTaskManager
extends Object

Component for managing worker tasks.

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`alterWarehouse(WorkerId workerId, Identifier warehouse)`	Alters a worker task warehouse
`void`	`createWorkerTask(WorkerId workerId)`	Creates a new worker task.
`void`	`dropWorkerTask(WorkerId workerId)`	Drops a worker task.
`static WorkerTaskManager`	`from(Session session, Identifier instanceSchema)`	Creates a new `WorkerTaskManager`.
`void`	`resumeWorkerTask(WorkerId workerId)`	Resumes a worker task if it exists.
`void`	`suspendWorkerTaskIfExists(WorkerId workerId)`	Suspends a worker task if it exists.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Method Detail
  - from
```
public static WorkerTaskManager from(Session session,
                                     Identifier instanceSchema)
```
    Creates a new WorkerTaskManager.
    
    Parameters:
    
    session - Snowpark session object
    
    instanceSchema - task reactor instance schema name
    
    Returns:
    
    new manager instance
  - createWorkerTask
```
public void createWorkerTask(WorkerId workerId)
```
    Creates a new worker task.
    
    Parameters:
    
    workerId - worker id
  - dropWorkerTask
```
public void dropWorkerTask(WorkerId workerId)
```
    Drops a worker task.
    Throws SnowflakeSQLException if the queue does not exist.
    
    Parameters:
    
    workerId - worker id
  - alterWarehouse
```
public void alterWarehouse(WorkerId workerId,
                           Identifier warehouse)
```
    Alters a worker task warehouse
    Throws SnowflakeSQLException if the queue does not exist.
    
    Parameters:
    
    workerId - worker id
    
    warehouse - new warehouse
  - suspendWorkerTaskIfExists
```
public void suspendWorkerTaskIfExists(WorkerId workerId)
```
    Suspends a worker task if it exists.
    
    Parameters:
    
    workerId - worker id
  - resumeWorkerTask
```
public void resumeWorkerTask(WorkerId workerId)
```
    Resumes a worker task if it exists.
    
    Parameters:
    
    workerId - worker id