|
@@ -8,7 +8,7 @@ import asyncio.subprocess as subprocess
|
|
|
import asyncio
|
|
import asyncio
|
|
|
from watchfiles import awatch, watch
|
|
from watchfiles import awatch, watch
|
|
|
from termcolor import colored
|
|
from termcolor import colored
|
|
|
-
|
|
|
|
|
|
|
+from datetime import datetime
|
|
|
|
|
|
|
|
|
|
|
|
|
async def on_modified(event):
|
|
async def on_modified(event):
|
|
@@ -17,6 +17,7 @@ async def on_modified(event):
|
|
|
stdout, _ = await p.communicate()
|
|
stdout, _ = await p.communicate()
|
|
|
if b'error' in stdout:
|
|
if b'error' in stdout:
|
|
|
print(stdout.decode('utf-8'))
|
|
print(stdout.decode('utf-8'))
|
|
|
|
|
+ print(datetime.now(), '-' * 40)
|
|
|
return
|
|
return
|
|
|
|
|
|
|
|
for sql in sqls:
|
|
for sql in sqls:
|
|
@@ -35,7 +36,7 @@ async def on_modified(event):
|
|
|
if return_code != 0:
|
|
if return_code != 0:
|
|
|
print(f'{return_code=}')
|
|
print(f'{return_code=}')
|
|
|
break
|
|
break
|
|
|
- print('-'*40)
|
|
|
|
|
|
|
+ print(datetime.now(), '-' * 40)
|
|
|
|
|
|
|
|
async def main():
|
|
async def main():
|
|
|
async for changes in awatch('src'):
|
|
async for changes in awatch('src'):
|
myuan