mirror of
https://github.com/xcat2/confluent.git
synced 2026-09-04 12:07:58 +00:00
Remove derelict devnull open
This was leftover from pre-async days to support old subprocess mechanism.
This commit is contained in:
@@ -1262,11 +1262,10 @@ class MediaImporter(object):
|
||||
async def importmedia(self):
|
||||
if self.medfile:
|
||||
os.environ['CONFLUENT_MEDIAFD'] = '{0}'.format(self.medfile.fileno())
|
||||
with open(os.devnull, 'w'):
|
||||
self.worker = await asyncio.create_subprocess_exec(
|
||||
sys.executable, __file__, self.filename, '-b',
|
||||
self.targpath, self.distpath, self.customname,
|
||||
stdout=asyncio.subprocess.PIPE, close_fds=False)
|
||||
self.worker = await asyncio.create_subprocess_exec(
|
||||
sys.executable, __file__, self.filename, '-b',
|
||||
self.targpath, self.distpath, self.customname,
|
||||
stdout=asyncio.subprocess.PIPE, close_fds=False)
|
||||
wkr = self.worker
|
||||
currline = b''
|
||||
while wkr.returncode is None:
|
||||
|
||||
Reference in New Issue
Block a user