File tree Expand file tree Collapse file tree 1 file changed +3
-2
lines changed
Expand file tree Collapse file tree 1 file changed +3
-2
lines changed Original file line number Diff line number Diff line change 88
99
1010SRUID = "octue/openfast-service:0.10.2"
11+ PROJECT_ID = "octue-twined-services"
1112
1213
1314@unittest .skipUnless (
@@ -23,7 +24,7 @@ def test_single_question(self):
2324 datasets = {"openfast" : "gs://octue-octue-twined-services-octue-twined/openfast-service/testing/openfast_iea" }
2425 )
2526
26- child = Child (id = SRUID , backend = {"name" : "GCPPubSubBackend" , "project_name" : os . environ [ "TEST_PROJECT_NAME" ] })
27+ child = Child (id = SRUID , backend = {"name" : "GCPPubSubBackend" , "project_name" : PROJECT_ID })
2728
2829 answer , question_uuid = child .ask (input_manifest = input_manifest , timeout = 3600 )
2930 self .assertEqual (len (answer ["output_manifest" ].datasets ), 1 )
@@ -36,7 +37,7 @@ def test_multiple_parallel_questions(self):
3637 """Test that multiple parallel questions are answered correctly."""
3738 number_of_questions = 50
3839 input_manifest = Manifest (datasets = {"openfast" : "gs://octue-openfast-test-data/openfast_iea" })
39- child = Child (id = SRUID , backend = {"name" : "GCPPubSubBackend" , "project_name" : os . environ [ "TEST_PROJECT_NAME" ] })
40+ child = Child (id = SRUID , backend = {"name" : "GCPPubSubBackend" , "project_name" : PROJECT_ID })
4041
4142 questions = [{"input_manifest" : input_manifest , "timeout" : 3600 } for _ in range (number_of_questions )]
4243 answers = child .ask_multiple (* questions , max_workers = 50 )
You can’t perform that action at this time.
0 commit comments