def transform_data()

in modules/harness-build-flex-template/pubsub_dataflow_bigquery/pubsub_transform_bigquery.py [0:0]

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

def transform_data(message):
    """
    The "message" input is a json object representing the data
    read from the Pub/Sub subscription or topic.
    Replace this code example with your own data transformation.
    """
    message['Issue_Date'] = message['Issue_Date'].replace("/", "-")
    return message