create_flow_run(self, deployment_id: UUID, flow_run_create: DeploymentFlowRunCreate) -> Response

pause_deployment(self, deployment_id: UUID) -> Response

pause_work_pool(self, work_pool_name: str) -> Response

pause_work_queue(self, work_queue_id: UUID) -> Response

read_block_document_raw(self, block_document_id: UUID, include_secrets: bool = True) -> Response

read_concurrency_limit_v2_raw(self, concurrency_limit_id: UUID) -> Response

read_deployment(self, deployment_id: UUID) -> Optional[DeploymentResponse]

read_deployment_raw(self, deployment_id: UUID) -> Response

read_flow_raw(self, flow_id: UUID) -> Response

read_flow_run_raw(self, flow_run_id: UUID) -> Response

read_task_run_raw(self, task_run_id: UUID) -> Response

read_work_pool(self, work_pool_id: UUID) -> Optional[WorkPool]

read_work_pool_raw(self, work_pool_id: UUID) -> Response

read_work_queue_raw(self, work_queue_id: UUID) -> Response

read_work_queue_status_raw(self, work_queue_id: UUID) -> Response

read_workspace_variables(self, names: Optional[List[str]] = None) -> Dict[str, StrictVariableValue]

request(self, method: HTTP_METHODS, path: 'ServerRoutes', params: dict[str, Any] | None = None, path_params: dict[str, Any] | None = None, **kwargs: Any) -> 'Response'

resume_deployment(self, deployment_id: UUID) -> Response

resume_flow_run(self, flow_run_id: UUID) -> OrchestrationResult

resume_work_pool(self, work_pool_name: str) -> Response

resume_work_queue(self, work_queue_id: UUID) -> Response

set_flow_run_state(self, flow_run_id: UUID, state: StateCreate) -> Response

read_work_pool(self, work_pool_name: str) -> WorkPool

request(self, method: HTTP_METHODS, path: 'ServerRoutes', params: dict[str, Any] | None = None, path_params: dict[str, Any] | None = None, **kwargs: Any) -> 'Response'