Skip to content

get_import_job async 

get_import_job(
    application_id: __string,
    job_id: __string,
    *,
    config_overrides: Optional[AsyncPinpointClientConfig] = None,
) -> GetImportJobResponse

Retrieves information about the status and settings of a specific import job for an application.

Parameters:

  • application_id (__string) –

    The unique identifier for the application. This identifier is displayed as the Project ID on the Amazon Pinpoint console.

  • job_id (__string) –

    The unique identifier for the job.

Raises:

Source code in docs_src/capo_pinpoint/_services/async_pinpoint.py 
3695
3696
3697
3698
3699
3700
3701
3702
3703
3704
3705
3706
3707
3708
3709
3710
3711
3712
3713
3714
3715
3716
3717
3718
3719
3720
3721
3722
3723
3724
3725
3726
3727
3728
3729
3730
3731
3732
3733
3734
3735
3736
3737
3738
3739
3740
3741
3742
3743
3744
3745
3746
3747
3748
async def get_import_job(
    self,
    application_id: "capo_pinpoint.types.__string.__string",
    job_id: "capo_pinpoint.types.__string.__string",
    *,
    config_overrides: Optional[AsyncPinpointClientConfig] = None,
) -> "capo_pinpoint.types.get_import_job_response.GetImportJobResponse":
    """<p>Retrieves information about the status and settings of a specific import job for an application.</p>

    Args:
        application_id: <p>The unique identifier for the application. This identifier is displayed as the <b>Project ID</b> on the Amazon Pinpoint console.</p>
        job_id: <p>The unique identifier for the job.</p>

    Raises:
        capo_pinpoint.errors.bad_request_exception.BadRequestException: <p>Provides information about an API request or response.</p>
        capo_pinpoint.errors.forbidden_exception.ForbiddenException: <p>Provides information about an API request or response.</p>
        capo_pinpoint.errors.internal_server_error_exception.InternalServerErrorException: <p>Provides information about an API request or response.</p>
        capo_pinpoint.errors.method_not_allowed_exception.MethodNotAllowedException: <p>Provides information about an API request or response.</p>
        capo_pinpoint.errors.not_found_exception.NotFoundException: <p>Provides information about an API request or response.</p>
        capo_pinpoint.errors.payload_too_large_exception.PayloadTooLargeException: <p>Provides information about an API request or response.</p>
        capo_pinpoint.errors.too_many_requests_exception.TooManyRequestsException: <p>Provides information about an API request or response.</p>
        capo_pinpoint.errors.UnknownServiceError: The service returned an error code this client does not model.
    """

    async def _handler(
        req: "AsyncOperationRequest[capo_pinpoint.types.get_import_job_request.GetImportJobRequest]",
    ) -> AsyncOperationResponse[
        "capo_pinpoint.types.get_import_job_response.GetImportJobResponse"
    ]:
        import capo_pinpoint._operations.pinpoint.get_import_job

        (
            output,
            http_response,
        ) = await capo_pinpoint._operations.pinpoint.get_import_job.async_get_import_job(
            req.options, req.input
        )
        return AsyncOperationResponse(output=output, response=http_response)

    interceptors_, options_ = self.operation_options(
        config_overrides, OperationLogging("GetImportJob")
    )
    input_: capo_pinpoint.types.get_import_job_request.GetImportJobRequest = {
        "application_id": application_id,
        "job_id": job_id,
    }

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