yerang commited on
Commit
8daa604
·
verified ·
1 Parent(s): 738eb00

Update stf_utils.py

Browse files
Files changed (1) hide show
  1. stf_utils.py +16 -32
stf_utils.py CHANGED
@@ -132,39 +132,23 @@ class STFPipeline:
132
  results = []
133
 
134
 
135
-
136
- try:
137
- # 순차적으로 gen_infer를 실행
138
- gen_infer = self.template.gen_infer(audio_segment, pivot)
139
 
140
- for idx, (it, chunk) in enumerate(gen_infer, pivot):
141
- frame = next(reader) # 다음 프레임을 읽음
142
- composed = self.template.compose(idx, frame, it) # 합성 작업 수행
143
- frame_name = f"{idx}".zfill(5) + ".jpg"
144
- results.append(it['pred']) # 결과를 저장
145
- pivot = idx + 1
146
-
147
- except StopIteration as e:
148
- pass
149
-
150
-
151
-
152
- # with ThreadPoolExecutor(4) as p:
153
- # try:
154
-
155
- # gen_infer = self.template.gen_infer_concurrent(
156
- # p,
157
- # audio_segment,
158
- # pivot,
159
- # )
160
- # for idx, (it, chunk) in enumerate(gen_infer, pivot):
161
- # frame = next(reader)
162
- # composed = self.template.compose(idx, frame, it)
163
- # frame_name = f"{idx}".zfill(5)+".jpg"
164
- # results.append(it['pred'])
165
- # pivot = idx + 1
166
- # except StopIteration as e:
167
- # pass
168
 
169
  print('STFPipeline execute 3')
170
  images2video(results, save_path)
 
132
  results = []
133
 
134
 
 
 
 
 
135
 
136
+ with ThreadPoolExecutor(4) as p:
137
+ try:
138
+
139
+ gen_infer = self.template.gen_infer_concurrent(
140
+ p,
141
+ audio_segment,
142
+ pivot,
143
+ )
144
+ for idx, (it, chunk) in enumerate(gen_infer, pivot):
145
+ frame = next(reader)
146
+ composed = self.template.compose(idx, frame, it)
147
+ frame_name = f"{idx}".zfill(5)+".jpg"
148
+ results.append(it['pred'])
149
+ pivot = idx + 1
150
+ except StopIteration as e:
151
+ pass
 
 
 
 
 
 
 
 
 
 
 
 
152
 
153
  print('STFPipeline execute 3')
154
  images2video(results, save_path)