async def METHOD_NAME(
    c,
    s,
    a,
    b,
    df_left,
    df_right,
    ddf_left,
    ddf_right_unknown,
    on,
    how,
):
    # Compute expected
    expected = df_left.merge(df_right, on=on, how=how)
    # Perform merge
    result_graph = ddf_left.merge(ddf_right_unknown, on=on, how=how, shuffle="p2p")
    result = await c.compute(result_graph)
    # Assertions
    assert_eq(result, expected)
    assert_eq(result_graph.divisions, tuple(None for _ in range(11)))