@@ -106,17 +106,12 @@ def create_computation_cb(url, **kwargs) -> CallbackResult:
106106 ],
107107 }
108108
109- assert "json_schema_extra" in ComputationTask .model_config
110- assert isinstance (ComputationTask . model_config [ "json_schema_extra " ], dict )
109+ json_schema = ComputationTask .model_json_schema ()
110+ assert isinstance (json_schema [ "examples " ], list )
111111 assert isinstance (
112- ComputationTask . model_config [ "json_schema_extra " ]["examples" ], list
112+ json_schema [ "examples " ][0 ], dict
113113 )
114- assert isinstance (
115- ComputationTask .model_config ["json_schema_extra" ]["examples" ][0 ], dict
116- )
117- computation : dict [str , Any ] = ComputationTask .model_config ["json_schema_extra" ][
118- "examples"
119- ][0 ].copy ()
114+ computation : dict [str , Any ] = json_schema ["examples" ][0 ].copy ()
120115 computation .update (
121116 {
122117 "id" : f"{ kwargs ['json' ]['project_id' ]} " ,
@@ -143,16 +138,16 @@ def get_computation_cb(url, **kwargs) -> CallbackResult:
143138 state = RunningState .NOT_STARTED
144139 pipeline : dict [str , list [str ]] = FULL_PROJECT_PIPELINE_ADJACENCY
145140 node_states = FULL_PROJECT_NODE_STATES
146- assert "json_schema_extra" in ComputationGet . model_config
147- assert isinstance ( ComputationGet . model_config [ "json_schema_extra" ], dict )
141+
142+ json_schema = ComputationTask . model_json_schema ( )
148143 assert isinstance (
149- ComputationGet . model_config [ "json_schema_extra" ] ["examples" ], list
144+ json_schema ["examples" ], list
150145 )
151146 assert isinstance (
152- ComputationGet . model_config [ "json_schema_extra" ] ["examples" ][0 ], dict
147+ json_schema ["examples" ][0 ], dict
153148 )
154149
155- computation : dict [str , Any ] = ComputationGet . model_config [ "json_schema_extra" ] [
150+ computation : dict [str , Any ] = json_schema [
156151 "examples"
157152 ][0 ].copy ()
158153 computation .update (
0 commit comments