Lines Matching defs:asyncio
23 import asyncio
55 SEM = asyncio.Semaphore(50)
57 COMMIT_LOCK = asyncio.Lock()
89 p = await asyncio.create_subprocess_exec(
91 stdout=asyncio.subprocess.DEVNULL,
92 stderr=asyncio.subprocess.DEVNULL,
102 p = await asyncio.create_subprocess_exec(
104 stdout=asyncio.subprocess.DEVNULL,
105 stderr=asyncio.subprocess.DEVNULL,
153 p = await asyncio.create_subprocess_exec(
155 stdout=asyncio.subprocess.DEVNULL,
156 stderr=asyncio.subprocess.PIPE,
174 p = await asyncio.create_subprocess_exec(
176 stdout=asyncio.subprocess.DEVNULL,
177 stderr=asyncio.subprocess.DEVNULL,
208 p = await asyncio.create_subprocess_exec(
210 stdout=asyncio.subprocess.PIPE,
211 stderr=asyncio.subprocess.DEVNULL)
215 p = await asyncio.create_subprocess_exec(
217 stdout=asyncio.subprocess.PIPE,
218 stderr=asyncio.subprocess.DEVNULL)
235 p = await asyncio.create_subprocess_exec(
237 stdout=asyncio.subprocess.DEVNULL,
238 stderr=asyncio.subprocess.DEVNULL,
246 p = await asyncio.create_subprocess_exec(
248 stdout=asyncio.subprocess.PIPE,
249 stderr=asyncio.subprocess.DEVNULL,
259 p = await asyncio.create_subprocess_exec(
261 stdout=asyncio.subprocess.PIPE,
262 stderr=asyncio.subprocess.DEVNULL,
345 # collected by asyncio.gather. We do this to allow the tasks to be
358 tasks.append(asyncio.ensure_future(
361 await asyncio.gather(*tasks)
387 asyncio.ensure_future(commit_state(message=f'Update to {commits[0].sha}'))