def METHOD_NAME(client, flow_name, data_resource, engine):
    sql1 = extract(data_resource, DataObject.SENTIMENT)
    sql2 = extract(data_resource, DataObject.SENTIMENT)
    metric_input = constant_metric(sql1)
    metric_output = metric_with_multiple_inputs(sql1, metric_input, sql2)
    assert metric_output.get() == 27.5
    publish_flow_test(
        client,
        metric_output,
        name=flow_name(),
        engine=engine,
    )