@@ -2545,7 +2545,7 @@ def test_query_response_from_dict(self):
2545
2545
self .assertEqual (query_response_from_dict .data [0 ].aggregation , "string" )
2546
2546
self .assertEqual (query_response_from_dict .message , "string" )
2547
2547
self .assertEqual (query_response_from_dict .info .usage , 2 )
2548
- self .assertEqual (query_response_from_dict .info .usage_unit , 2 )
2548
+ self .assertEqual (query_response_from_dict .info .usage_unit , "bytes" )
2549
2549
self .assertEqual (query_response_from_dict .info .max_usage , 2.2 )
2550
2550
self .assertEqual (query_response_from_dict .info .size , 2 )
2551
2551
self .assertEqual (query_response_from_dict .info .max_size , 2.2 )
@@ -2609,7 +2609,7 @@ def test_query_response_to_dict(self):
2609
2609
self .assertEqual (query_response_to_dict ["data" ][0 ]["aggregation" ], "string" )
2610
2610
self .assertEqual (query_response_to_dict ["message" ], "string" )
2611
2611
self .assertEqual (query_response_to_dict ["info" ]["usage" ], 2 )
2612
- self .assertEqual (query_response_to_dict ["info" ]["usage_unit" ], 2 )
2612
+ self .assertEqual (query_response_to_dict ["info" ]["usage_unit" ], "bytes" )
2613
2613
self .assertEqual (query_response_to_dict ["info" ]["max_usage" ], 2.2 )
2614
2614
self .assertEqual (query_response_to_dict ["info" ]["size" ], 2 )
2615
2615
self .assertEqual (query_response_to_dict ["info" ]["max_size" ], 2.2 )
@@ -2674,7 +2674,7 @@ def test_query_response_from_json(self):
2674
2674
self .assertEqual (query_response_from_json .data [0 ].aggregation , "string" )
2675
2675
self .assertEqual (query_response_from_json .message , "string" )
2676
2676
self .assertEqual (query_response_from_json .info .usage , 2 )
2677
- self .assertEqual (query_response_from_json .info .usage_unit , 2 )
2677
+ self .assertEqual (query_response_from_json .info .usage_unit , "bytes" )
2678
2678
self .assertEqual (query_response_from_json .info .max_usage , 2.2 )
2679
2679
self .assertEqual (query_response_from_json .info .size , 2 )
2680
2680
self .assertEqual (query_response_from_json .info .max_size , 2.2 )
@@ -3895,7 +3895,6 @@ def test_processor_to_json(self):
3895
3895
"publish" : True ,
3896
3896
"debug" : True ,
3897
3897
"autoIngest" : True ,
3898
- "dryRun" : True ,
3899
3898
"notification" :
3900
3899
{
3901
3900
"type" : "rabbitmq" ,
@@ -3999,7 +3998,6 @@ def test_processor_to_json(self):
3999
3998
"publish": true,
4000
3999
"debug": true,
4001
4000
"autoIngest": true,
4002
- "dryRun": true,
4003
4001
"notification":
4004
4002
{
4005
4003
"type": "rabbitmq",
@@ -4486,7 +4484,6 @@ def test_query_init(self):
4486
4484
query .processor = [processor ]
4487
4485
query .debug = True
4488
4486
query .auto_ingest = True
4489
- query .dry_run = True
4490
4487
except Exception as ex :
4491
4488
got_exception = True
4492
4489
@@ -4532,7 +4529,6 @@ def test_query_init(self):
4532
4529
self .assertEqual (query .processor [0 ].options [0 ].value , "string" )
4533
4530
self .assertEqual (query .debug , True )
4534
4531
self .assertEqual (query .auto_ingest , True )
4535
- self .assertEqual (query .dry_run , True )
4536
4532
4537
4533
#
4538
4534
def test_query_from_dict (self ):
@@ -4580,7 +4576,6 @@ def test_query_from_dict(self):
4580
4576
self .assertEqual (query_from_dict .publish , True )
4581
4577
self .assertEqual (query_from_dict .debug , True )
4582
4578
self .assertEqual (query_from_dict .auto_ingest , True )
4583
- self .assertEqual (query_from_dict .dry_run , True )
4584
4579
self .assertEqual (query_from_dict .notification .type , "rabbitmq" )
4585
4580
self .assertEqual (query_from_dict .notification .host , "string" )
4586
4581
self .assertEqual (query_from_dict .notification .queue , "string" )
@@ -4646,7 +4641,6 @@ def test_query_to_dict(self):
4646
4641
self .assertEqual (query_to_dict ["publish" ], True )
4647
4642
self .assertEqual (query_to_dict ["debug" ], True )
4648
4643
self .assertEqual (query_to_dict ["auto_ingest" ], True )
4649
- self .assertEqual (query_to_dict ["dry_run" ], True )
4650
4644
self .assertEqual (query_to_dict ["notification" ]["type" ], "rabbitmq" )
4651
4645
self .assertEqual (query_to_dict ["notification" ]["host" ], "string" )
4652
4646
self .assertEqual (query_to_dict ["notification" ]["queue" ], "string" )
@@ -4712,7 +4706,6 @@ def test_query_to_dict_query_post(self):
4712
4706
self .assertEqual (query_to_dict_query_post ["publish" ], True )
4713
4707
self .assertEqual (query_to_dict_query_post ["debug" ], True )
4714
4708
self .assertEqual (query_to_dict_query_post ["autoIngest" ], True )
4715
- self .assertEqual (query_to_dict_query_post ["dryRun" ], True )
4716
4709
self .assertEqual (query_to_dict_query_post ["notification" ]["type" ], "rabbitmq" )
4717
4710
self .assertEqual (query_to_dict_query_post ["notification" ]["host" ], "string" )
4718
4711
self .assertEqual (query_to_dict_query_post ["notification" ]["queue" ], "string" )
@@ -4776,7 +4769,6 @@ def test_query_from_json(self):
4776
4769
self .assertEqual (query_from_json .publish , True )
4777
4770
self .assertEqual (query_from_json .debug , True )
4778
4771
self .assertEqual (query_from_json .auto_ingest , True )
4779
- self .assertEqual (query_from_json .dry_run , True )
4780
4772
self .assertEqual (query_from_json .notification .type , "rabbitmq" )
4781
4773
self .assertEqual (query_from_json .notification .host , "string" )
4782
4774
self .assertEqual (query_from_json .notification .queue , "string" )
@@ -4792,11 +4784,6 @@ def test_query_from_json(self):
4792
4784
self .assertEqual (query_from_json .processor [1 ].type , "string2" )
4793
4785
self .assertEqual (query_from_json .processor [1 ].options [0 ].name , "string2" )
4794
4786
self .assertEqual (query_from_json .processor [1 ].options [0 ].value , "string2" )
4795
- self .assertEqual (query_from_json .info .size , 2 )
4796
- self .assertEqual (query_from_json .info .max_size , 1.2 )
4797
- self .assertEqual (query_from_json .info .count , 2 )
4798
- self .assertEqual (query_from_json .info .interactive_max_count , 2 )
4799
- self .assertEqual (query_from_json .info .max_count , 2 )
4800
4787
4801
4788
#
4802
4789
def test_query_to_json (self ):
0 commit comments