Skip to content

Commit

Permalink
Adjust for removal of default HDFS server testing
Browse files Browse the repository at this point in the history
  • Loading branch information
muthumala19 committed Jan 2, 2025
1 parent de4cffa commit 68e8885
Showing 1 changed file with 13 additions and 15 deletions.
28 changes: 13 additions & 15 deletions tests/integration/test.py
Original file line number Diff line number Diff line change
Expand Up @@ -230,40 +230,38 @@ def test(host, port):
print()
logging.info('Testing lst after adhdfs')
send_and_expect_response(sock, 'lst after adhdfs', LIST,
b'|1|/home/data/powergrid.dl|hdfs:/home/data/powergrid.dl|op|'
+ LINE_END +
b'|2|/home/powergrid.dl|hdfs:/home/powergrid.dl|op|',
b'|1|/home/powergrid.dl|hdfs:/home/powergrid.dl|op|',
exit_on_failure=True)

print()
logging.info('1. Testing ecnt after adhdfs')
send_and_expect_response(sock, 'ecnt', ECNT, b'graphid-send', exit_on_failure=True)
send_and_expect_response(sock, 'ecnt', b'1', b'6594', exit_on_failure=True)

print()
logging.info('2. Testing ecnt after adhdfs')
send_and_expect_response(sock, 'ecnt', ECNT, b'graphid-send', exit_on_failure=True)
send_and_expect_response(sock, 'ecnt', b'2', b'6594', exit_on_failure=True)
# print()
# logging.info('2. Testing ecnt after adhdfs')
# send_and_expect_response(sock, 'ecnt', ECNT, b'graphid-send', exit_on_failure=True)
# send_and_expect_response(sock, 'ecnt', b'2', b'6594', exit_on_failure=True)

print()
logging.info('1. Testing vcnt after adhdfs')
send_and_expect_response(sock, 'vcnt', VCNT, b'graphid-send', exit_on_failure=True)
send_and_expect_response(sock, 'vcnt', b'1', b'4941', exit_on_failure=True)

print()
logging.info('2. Testing vcnt after adhdfs')
send_and_expect_response(sock, 'vcnt', VCNT, b'graphid-send', exit_on_failure=True)
send_and_expect_response(sock, 'vcnt', b'2', b'4941', exit_on_failure=True)
# print()
# logging.info('2. Testing vcnt after adhdfs')
# send_and_expect_response(sock, 'vcnt', VCNT, b'graphid-send', exit_on_failure=True)
# send_and_expect_response(sock, 'vcnt', b'2', b'4941', exit_on_failure=True)

print()
logging.info('1. Testing rmgr after adhdfs')
send_and_expect_response(sock, 'rmgr', RMGR, SEND, exit_on_failure=True)
send_and_expect_response(sock, 'rmgr', b'1', DONE, exit_on_failure=True)

print()
logging.info('2. Testing rmgr after adhdfs')
send_and_expect_response(sock, 'rmgr', RMGR, SEND, exit_on_failure=True)
send_and_expect_response(sock, 'rmgr', b'2', DONE, exit_on_failure=True)
# print()
# logging.info('2. Testing rmgr after adhdfs')
# send_and_expect_response(sock, 'rmgr', RMGR, SEND, exit_on_failure=True)
# send_and_expect_response(sock, 'rmgr', b'2', DONE, exit_on_failure=True)

print()
logging.info('Testing lst after adhdfs')
Expand Down

0 comments on commit 68e8885

Please sign in to comment.