in retail/recommendation-system/bqml-mlops/part_2/pipeline.py [0:0]
def train_matrix_factorization_model(ddlop, project_id: str, dataset: str): query = """