@@ -6,7 +6,7 @@ use std::sync::Arc;
6
6
use std:: time:: Duration ;
7
7
8
8
use assert_json_diff:: assert_json_eq;
9
- use graph:: blockchain:: block_stream:: { BlockWithTriggers , EntityOperationKind } ;
9
+ use graph:: blockchain:: block_stream:: BlockWithTriggers ;
10
10
use graph:: blockchain:: { Block , BlockPtr , Blockchain } ;
11
11
use graph:: data:: store:: scalar:: Bytes ;
12
12
use graph:: data:: subgraph:: schema:: { SubgraphError , SubgraphHealth } ;
@@ -18,12 +18,11 @@ use graph::object;
18
18
use graph:: prelude:: ethabi:: ethereum_types:: H256 ;
19
19
use graph:: prelude:: web3:: types:: Address ;
20
20
use graph:: prelude:: {
21
- hex, CheapClone , DeploymentHash , SubgraphAssignmentProvider , SubgraphName , SubgraphStore , Value ,
21
+ hex, CheapClone , DeploymentHash , SubgraphAssignmentProvider , SubgraphName , SubgraphStore ,
22
22
} ;
23
- use graph:: schema:: InputSchema ;
24
23
use graph_tests:: fixture:: ethereum:: {
25
24
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,
27
26
} ;
28
27
29
28
use graph_tests:: fixture:: substreams:: chain as substreams_chain;
@@ -1091,54 +1090,6 @@ async fn parse_data_source_context() {
1091
1090
) ;
1092
1091
}
1093
1092
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
-
1142
1093
#[ tokio:: test]
1143
1094
async fn retry_create_ds ( ) {
1144
1095
let RunnerTestRecipe { stores, test_info } =
0 commit comments