def add_s3_tag()

in dags/processing/processing.py [0:0]

• 17 lines of code
• 1 McCabe index (conditional complexity)

def add_s3_tag(tag_key, tag_value, bucket, key):
    import boto3

    print(f"Setting key {tag_key} to value {tag_value}.")
    s3_client = boto3.client('s3')
    response = s3_client.put_object_tagging(
        Bucket=bucket,
        Key=key,
        Tagging={
            'TagSet': [
                {
                    'Key': tag_key,
                    'Value': tag_value
                }
            ]
        }
    )

    print(f"Metadata setting response {response}")