def handle_post()

in processing-pipelines/bigquery/notifier/python/app.py [0:0]

• 9 lines of code
• 3 McCabe index (conditional complexity)

def handle_post():
    app.logger.info(pretty_print_POST(request))

    # Read CloudEvent from the request
    cloud_event = from_http(request.headers, request.get_data())

    # Parse the event body
    bucket, name = read_event_data(cloud_event)

    # This is only needed in Cloud Run (Managed) when the
    # events are not filtered by bucket yet.
    if bucket_expected is not None and bucket != bucket_expected:
        app.logger.info(f"Input bucket '{bucket}' does not match with expected bucket '{bucket_expected}'")
    else:
        notify(bucket, name)

    return 'OK', 200