How to update docker lambda to use the latest docker image using code pipeline

[ankit-agrawal-berlin]

Hi All,
I am trying to use CDK to create a pipeline for ECR image. I want whenever a new image is pushed to ECR with latest tag then that should be updated in lambda . I don't want the execution of the lambda, but just want to update the lambda. I create the below CDK python script, but it always try to deploy it instead of just updating the function.

from typing import Any
from aws_cdk import (
    aws_lambda as _lambda,
    aws_codepipeline as codepipeline,
    aws_codepipeline_actions as codepipeline_actions,
    aws_s3 as s3,
    aws_iam as iam,
    aws_ec2 as ec2,
    Stack, Duration
)
from constructs import Construct

from cdk.service.ecr_construct import ECRConstruct


class DataIngestionLambdaPipelineStack(Stack):

    def __init__(self, scope: Construct, id: str, vpc: ec2.Vpc, **kwargs: Any) -> None:
        super().__init__(scope, id, **kwargs)

        self.ecr_stack = ECRConstruct(
            self, "data-validation", vpc=vpc)

        lambda_function = _lambda.DockerImageFunction(
            self, "ValidationLambda",
            code=_lambda.DockerImageCode.from_ecr(self.ecr_stack.ecr_repository),
            timeout=Duration.minutes(15),
            memory_size=3008,
        )

        account_number = Stack.of(self).account
        data_bucket = s3.Bucket(
            self, "DataBucket",
            bucket_name=f"data-bucket-{account_number}",
            versioned=True
        )
        lambda_function.add_to_role_policy(
            iam.PolicyStatement(
                actions=[
                    "s3:GetObject",
                    "s3:PutObject",
                    "s3:ListBucket"
                ],
                resources=[
                    f"arn:aws:s3:::{data_bucket.bucket_name}/*",
                    f"arn:aws:s3:::{data_bucket.bucket_name}"
                ]
            )
        )
        lambda_function.add_to_role_policy(
            iam.PolicyStatement(
                actions=[
                    "codepipeline:PutJobSuccessResult",
                    "codepipeline:PutJobFailureResult"
                ],
                resources=["*"]
            )
        )

        # Create CodePipeline
        self.pipeline = codepipeline.Pipeline(
            self, "DataValidation",
            stages=[
                codepipeline.StageProps(
                    stage_name="Source",
                    actions=[
                        codepipeline_actions.EcrSourceAction(
                            action_name="ECR_Source",
                            repository=self.ecr_stack.ecr_repository,
                            image_tag="latest",
                            output=codepipeline.Artifact(),
                        ),
                    ]
                ),
                codepipeline.StageProps(
                    stage_name="Deploy",
                    actions=[
                        codepipeline_actions.LambdaInvokeAction(
                            action_name="Lambda_Deploy",
                            lambda_=lambda_function,
                        ),
                    ]
                ),
            ]
        )