@@ -13,6 +13,7 @@ use diesel::{
1313 sql_query,
1414 sql_types:: { Nullable , Text } ,
1515} ;
16+ use graph:: semver:: Version ;
1617use graph:: {
1718 blockchain:: block_stream:: FirehoseCursor , data:: subgraph:: schema:: SubgraphError , env:: ENV_VARS ,
1819 schema:: EntityType ,
@@ -301,11 +302,12 @@ pub fn debug_fork(
301302
302303pub fn schema ( conn : & mut PgConnection , site : & Site ) -> Result < ( InputSchema , bool ) , StoreError > {
303304 use subgraph_manifest as sm;
304- let ( s, use_bytea_prefix) = sm:: table
305- . select ( ( sm:: schema, sm:: use_bytea_prefix) )
305+ let ( s, spec_ver , use_bytea_prefix) = sm:: table
306+ . select ( ( sm:: schema, sm:: spec_version , sm :: use_bytea_prefix) )
306307 . filter ( sm:: id. eq ( site. id ) )
307- . first :: < ( String , bool ) > ( conn) ?;
308- InputSchema :: parse_latest ( s. as_str ( ) , site. deployment . clone ( ) )
308+ . first :: < ( String , String , bool ) > ( conn) ?;
309+ let spec_version = Version :: parse ( spec_ver. as_str ( ) ) . unwrap ( ) ;
310+ InputSchema :: parse ( & spec_version, s. as_str ( ) , site. deployment . clone ( ) )
309311 . map_err ( StoreError :: Unknown )
310312 . map ( |schema| ( schema, use_bytea_prefix) )
311313}
0 commit comments