@@ -468,15 +468,18 @@ def beamformtest(self, tests=None):
468
468
testdir = os .path .abspath (pjoin (self .testdir , testname ))
469
469
os .makedirs (pjoin (testdir , f"output_beamform" ), exist_ok = True )
470
470
log = pjoin (testdir , f"output_beamform" , "stdouterr.log" )
471
- for btype , copt in [("tx" , "" ), ("rx" , f"-c input_{ dataname [0 ]} /{ dataname [3 ]} " )]:
472
- cmd = [f"""time beamform_{ btype } .py -i input_{ dataname [0 ]} /{ dataname [1 ]} \
473
- -a input_{ dataname [0 ]} /{ dataname [2 ]} { copt } \
474
- -o output_beamform/beamform_{ btype } _output.txt""" ]
475
- try :
476
- self .distribrun (testdir , cmd , logfile = log , dataname = dataname [0 ], nisarimg = True ,
477
- loghdlrname = f"wftest.{ os .path .basename (testdir )} " )
478
- except subprocess .CalledProcessError as e :
479
- raise RuntimeError (f"CalTool beamformer tool test { testname } failed" ) from e
471
+ cmd = [f"""time beamform_tx.py -i input_{ dataname [0 ]} /{ dataname [1 ]} \
472
+ -a input_{ dataname [0 ]} /{ dataname [2 ]} \
473
+ -o output_beamform/beamform_tx_output.txt""" ,
474
+ f"""time beamform_rx.py -i input_{ dataname [0 ]} /{ dataname [1 ]} \
475
+ -a input_{ dataname [0 ]} /{ dataname [2 ]} \
476
+ -c input_{ dataname [0 ]} /{ dataname [3 ]} \
477
+ -o output_beamform/beamform_rx_output.txt""" ]
478
+ try :
479
+ self .distribrun (testdir , cmd , logfile = log , dataname = dataname [0 ], nisarimg = True ,
480
+ loghdlrname = f"wftest.{ os .path .basename (testdir )} " )
481
+ except subprocess .CalledProcessError as e :
482
+ raise RuntimeError (f"CalTool beamformer tool test { testname } failed" ) from e
480
483
481
484
def mintests (self ):
482
485
"""
0 commit comments