Skip to content

Commit

Permalink
Fix test issue
Browse files Browse the repository at this point in the history
  • Loading branch information
boomanaiden154 committed Dec 19, 2024
1 parent fc9b027 commit 06be7fc
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 8 deletions.
Binary file not shown.
Original file line number Diff line number Diff line change
Expand Up @@ -947,9 +947,7 @@ def gen_trajectories(
)
not_done = result_futures
succeeded_idx = 0
succeeded: List[Optional[Tuple[Tuple[int, ProfilingDictValueType,
ProfilingDictValueType],
tf.train.SequenceExample]]] = []
succeeded = []

for written_files_idx in range(num_output_files):
written_per_file = 0
Expand All @@ -966,11 +964,8 @@ def gen_trajectories(
time_compiler_start = timeit.default_timer()
while not_done or succeeded:
(done, not_done) = concurrent.futures.wait(not_done, worker_wait_sec)
succeeded.extend([
r.result()
for r in done
if not r.cancelled() and r.exception() is None
])
succeeded.extend(
[r for r in done if not r.cancelled() and r.exception() is None])
failed = [r for r in done if r.exception() is not None]
for f in failed:
logging.info('Module failed with: %s', f.exception())
Expand Down

0 comments on commit 06be7fc

Please sign in to comment.