def METHOD_NAME(df_spark):
    settings = get_settings_dict()
    settings["link_type"] = "link_only"
    settings["source_dataset_column_name"] = "source_dataset"
    df_spark_a = df_spark.withColumn("source_dataset", f.lit("my_left_ds"))
    df_spark_b = df_spark.withColumn("source_dataset", f.lit("my_right_ds"))
    linker = SparkLinker(
        [df_spark_a, df_spark_b],
        settings,
        break_lineage_method="checkpoint",
        num_partitions_on_repartition=2,
    )
    df_predict = linker.predict().as_pandas_dataframe()
    assert len(df_predict) == 7257
    assert set(df_predict.source_dataset_l.values) == {"my_left_ds"}
    assert set(df_predict.source_dataset_r.values) == {"my_right_ds"}