Skip to content

Commit

Permalink
[FIX] - check if the runloop is closed
Browse files Browse the repository at this point in the history
  • Loading branch information
ceppelli committed Jun 24, 2020
1 parent ddabe6e commit 7640e73
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion .gitignore
Original file line number Diff line number Diff line change
@@ -1,9 +1,9 @@
# Miscellaneous
*.class
*.log
*.pyc
*.swp
.DS_Store
__pycache__

# venv
.venv
Expand Down
4 changes: 2 additions & 2 deletions src/magic_foundation/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@
from enum import Enum


__version__ = '0.1.5'
__version__ = '0.1.6'
__all__ = ('Main', 'Service', 'ServiceStatus', 'ServiceContext')

log = logging.getLogger(__name__)
Expand Down Expand Up @@ -61,7 +61,7 @@ async def coro():
future:concurrent.futures.Future = asyncio.run_coroutine_threadsafe(coro(), self._loop)
future.result()
else:
log.queue(f"[Queue][{self.label}] put 4 [thread id:{threading.current_thread().ident}] the runloop is closed.")
log.debug(f"[Queue][{self.label}] put 4 [thread id:{threading.current_thread().ident}] the runloop is closed.")

async def get(self):
return await self._queue.get()
Expand Down

0 comments on commit 7640e73

Please sign in to comment.