@@ -35,7 +35,7 @@ def train(
35
35
self ._query_runner .run_query (
36
36
"CALL gds.upload.graph($config)" ,
37
37
params = {
38
- "config" : {"mlTrainingConfig" : mlTrainingConfig , "graphName" : graph_name , "modelName" : model_name },
38
+ "config" : {"mlTrainingConfig" : mlTrainingConfig , "graphName" : graph_name , "modelName" : model_name , "mutateProperty" : "TODO,REMOVE" },
39
39
},
40
40
)
41
41
@@ -45,14 +45,17 @@ def predict(
45
45
model_name : str ,
46
46
feature_properties : List [str ],
47
47
relationship_types : List [str ],
48
+ mutateProperty : str ,
48
49
target_node_label : str = None ,
49
50
node_labels : List [str ] = None ,
50
51
) -> "Series[Any]" : # noqa: F821
51
52
mlConfigMap = {
52
53
"featureProperties" : feature_properties ,
53
54
"job_type" : "predict" ,
54
55
"nodeProperties" : feature_properties ,
55
- "relationshipTypes" : relationship_types
56
+ "relationshipTypes" : relationship_types ,
57
+ ##TODO cleanup the same from outside config
58
+ "mutateProperty" : mutateProperty
56
59
}
57
60
if target_node_label :
58
61
mlConfigMap ["targetNodeLabel" ] = target_node_label
@@ -63,6 +66,6 @@ def predict(
63
66
self ._query_runner .run_query (
64
67
"CALL gds.upload.graph($config)" ,
65
68
params = {
66
- "config" : {"mlTrainingConfig" : mlTrainingConfig , "graphName" : graph_name , "modelName" : model_name },
69
+ "config" : {"mlTrainingConfig" : mlTrainingConfig , "graphName" : graph_name , "modelName" : model_name , "mutateProperty" : mutateProperty },
67
70
},
68
71
) # type: ignore
0 commit comments