Add Pool.is_closing() method

asyncpg/pool.py

@@ -446,6 +446,14 @@ async def _initialize(self):
 
  await asyncio.gather(*connect_tasks)
 
+ @property
+ def closed(self):
+ """Return a boolean for whether this pool has already been closed/terminated.
+
+ .. versionadded:: 0.28.0
+ """
+ return self._closed
+
  def get_size(self):
  """Return the current number of connections in this pool.
 

tests/test_pool.py

@@ -740,6 +740,17 @@ async def test_pool_size_and_capacity(self):
  self.assertEqual(pool.get_size(), 3)
  self.assertEqual(pool.get_idle_size(), 0)
 
+ async def test_pool_closed(self):
+ async with self.create_pool() as pool:
+ self.assertFalse(pool.closed)
+ await pool.close()
+ self.assertTrue(pool.closed)
+
+ async with self.create_pool() as pool:
+ self.assertFalse(pool.closed)
+ await pool.terminate()
+ self.assertTrue(pool.closed)
+
  async def test_pool_handles_transaction_exit_in_asyncgen_1(self):
  pool = await self.create_pool(database='postgres',
  min_size=1, max_size=1)