File tree Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Expand file tree Collapse file tree 1 file changed +5
-3
lines changed Original file line number Diff line number Diff line change @@ -40,7 +40,8 @@ def test_build_spec_image_prefetch():
40
40
def test_commit_schema_to_stream_then_build ():
41
41
try :
42
42
if should_run_builder ():
43
- conn = redis .StrictRedis (port = 6379 )
43
+ db_port = int (os .getenv ("DATASINK_PORT" , "6379" ))
44
+ conn = redis .StrictRedis (port = db_port )
44
45
conn .ping ()
45
46
conn .flushall ()
46
47
builder_consumer_group_create (conn , "0" )
@@ -72,7 +73,7 @@ def test_commit_schema_to_stream_then_build():
72
73
)
73
74
assert new_builds_count == 1
74
75
assert len (build_stream_fields_arr ) == 1
75
- assert len (build_stream_fields_arr [0 ]["test_regexp " ]) == ".*"
76
+ assert len (build_stream_fields_arr [0 ]["tests_regexp " ]) == ".*"
76
77
assert conn .exists (STREAM_KEYNAME_NEW_BUILD_EVENTS )
77
78
conn .save ()
78
79
@@ -91,7 +92,8 @@ def should_run_builder():
91
92
def test_commit_schema_to_stream_then_build_historical_redis ():
92
93
try :
93
94
if should_run_builder ():
94
- conn = redis .StrictRedis (port = 6379 )
95
+ db_port = int (os .getenv ("DATASINK_PORT" , "6379" ))
96
+ conn = redis .StrictRedis (port = db_port )
95
97
conn .ping ()
96
98
conn .flushall ()
97
99
builder_consumer_group_create (conn , "0" )
You can’t perform that action at this time.
0 commit comments