@@ -6,7 +6,7 @@ use std::sync::Arc;
66use std:: time:: Duration ;
77
88use assert_json_diff:: assert_json_eq;
9- use graph:: blockchain:: block_stream:: { BlockWithTriggers , EntityOperationKind } ;
9+ use graph:: blockchain:: block_stream:: BlockWithTriggers ;
1010use graph:: blockchain:: { Block , BlockPtr , Blockchain } ;
1111use graph:: data:: store:: scalar:: Bytes ;
1212use graph:: data:: subgraph:: schema:: { SubgraphError , SubgraphHealth } ;
@@ -18,12 +18,11 @@ use graph::object;
1818use graph:: prelude:: ethabi:: ethereum_types:: H256 ;
1919use graph:: prelude:: web3:: types:: Address ;
2020use graph:: prelude:: {
21- hex, CheapClone , DeploymentHash , SubgraphAssignmentProvider , SubgraphName , SubgraphStore , Value ,
21+ hex, CheapClone , DeploymentHash , SubgraphAssignmentProvider , SubgraphName , SubgraphStore ,
2222} ;
23- use graph:: schema:: InputSchema ;
2423use graph_tests:: fixture:: ethereum:: {
2524 chain, empty_block, generate_empty_blocks_for_range, genesis, push_test_command, push_test_log,
26- push_test_polling_trigger, push_test_subgraph_trigger ,
25+ push_test_polling_trigger,
2726} ;
2827
2928use graph_tests:: fixture:: substreams:: chain as substreams_chain;
@@ -1091,54 +1090,6 @@ async fn parse_data_source_context() {
10911090 ) ;
10921091}
10931092
1094- #[ tokio:: test]
1095- async fn subgraph_data_sources ( ) {
1096- let RunnerTestRecipe { stores, test_info } =
1097- RunnerTestRecipe :: new ( "subgraph-data-sources" , "subgraph-data-sources" ) . await ;
1098-
1099- let schema = InputSchema :: parse_latest (
1100- "type User @entity { id: String!, val: String! }" ,
1101- DeploymentHash :: new ( "test" ) . unwrap ( ) ,
1102- )
1103- . unwrap ( ) ;
1104-
1105- let entity = schema
1106- . make_entity ( vec ! [
1107- ( "id" . into( ) , Value :: String ( "id" . to_owned( ) ) ) ,
1108- ( "val" . into( ) , Value :: String ( "DATA" . to_owned( ) ) ) ,
1109- ] )
1110- . unwrap ( ) ;
1111-
1112- let entity_type = schema. entity_type ( "User" ) . unwrap ( ) ;
1113-
1114- let blocks = {
1115- let block_0 = genesis ( ) ;
1116- let mut block_1 = empty_block ( block_0. ptr ( ) , test_ptr ( 1 ) ) ;
1117-
1118- push_test_subgraph_trigger (
1119- & mut block_1,
1120- DeploymentHash :: new ( "QmRFXhvyvbm4z5Lo7z2mN9Ckmo623uuB2jJYbRmAXgYKXJ" ) . unwrap ( ) ,
1121- entity,
1122- entity_type,
1123- EntityOperationKind :: Create ,
1124- 1 ,
1125- ) ;
1126-
1127- let block_2 = empty_block ( block_1. ptr ( ) , test_ptr ( 2 ) ) ;
1128- vec ! [ block_0, block_1, block_2]
1129- } ;
1130- let stop_block = blocks. last ( ) . unwrap ( ) . block . ptr ( ) ;
1131- let chain = chain ( & test_info. test_name , blocks, & stores, None ) . await ;
1132-
1133- let ctx = fixture:: setup ( & test_info, & stores, & chain, None , None ) . await ;
1134- let _ = ctx
1135- . runner ( stop_block)
1136- . await
1137- . run_for_test ( true )
1138- . await
1139- . unwrap ( ) ;
1140- }
1141-
11421093#[ tokio:: test]
11431094async fn retry_create_ds ( ) {
11441095 let RunnerTestRecipe { stores, test_info } =
0 commit comments