list_triggers async ¶

async def list_triggers(
    self,
    *,
    config_overrides: Optional[AsyncGlueClientConfig] = None,
    next_token: Optional["capo_glue.types.generic_string.GenericString"] = None,
    dependent_job_name: Optional["capo_glue.types.name_string.NameString"] = None,
    max_results: Optional[
        "capo_glue.types.orchestration_page_size200.OrchestrationPageSize200"
    ] = None,
    tags: Optional["capo_glue.types.tags_map.TagsMap"] = None,
) -> "capo_glue.types.list_triggers_response.ListTriggersResponse":
    """<p>Retrieves the names of all trigger resources in this Amazon Web Services account, or the resources with the specified tag. This operation allows you to see which resources are available in your account, and their names.</p> <p>This operation takes the optional <code>Tags</code> field, which you can use as a filter on the response so that tagged resources can be retrieved as a group. If you choose to use tags filtering, only resources with the tag are retrieved.</p>

    Args:
        next_token: <p>A continuation token, if this is a continuation request.</p>
        dependent_job_name: <p> The name of the job for which to retrieve triggers. The trigger that can start this job is returned. If there is no such trigger, all triggers are returned.</p>
        max_results: <p>The maximum size of a list to return.</p>
        tags: <p>Specifies to return only these tagged resources.</p>

    Raises:
        capo_glue.errors.entity_not_found_exception.EntityNotFoundException: <p>A specified entity does not exist</p>
        capo_glue.errors.internal_service_exception.InternalServiceException: <p>An internal service error occurred.</p>
        capo_glue.errors.invalid_input_exception.InvalidInputException: <p>The input provided was not valid.</p>
        capo_glue.errors.operation_timeout_exception.OperationTimeoutException: <p>The operation timed out.</p>
        capo_glue.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_glue.types.list_triggers_request.ListTriggersRequest]",
    ) -> AsyncOperationResponse[
        "capo_glue.types.list_triggers_response.ListTriggersResponse"
    ]:
        import capo_glue._operations.aws_glue.list_triggers

        (
            output,
            http_response,
        ) = await capo_glue._operations.aws_glue.list_triggers.async_list_triggers(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("ListTriggers")
    )
    input_: capo_glue.types.list_triggers_request.ListTriggersRequest = {}
    if next_token is not None:
        input_["next_token"] = next_token
    if dependent_job_name is not None:
        input_["dependent_job_name"] = dependent_job_name
    if max_results is not None:
        input_["max_results"] = max_results
    if tags is not None:
        input_["tags"] = tags

    response = await aexecute_pipeline(
        AsyncOperationRequest(input=input_, options=options_),
        handler=_handler,
        interceptors=list(interceptors_),
    )
    await response.response.aclose()
    return response.output