Commit 399ca6ff authored by Florin Chirica's avatar Florin Chirica
Browse files

Lint.

parent e2f2da4a
Showing with 3 additions and 7 deletions
+3 -7
......@@ -51,11 +51,7 @@ class CrawlStore:
)
)
await self.crawl_db.execute(
(
"CREATE TABLE IF NOT EXISTS good_peers(ip text)"
)
)
await self.crawl_db.execute(("CREATE TABLE IF NOT EXISTS good_peers(ip text)"))
await self.crawl_db.execute("CREATE INDEX IF NOT EXISTS ip_address on peer_records(ip_address)")
......@@ -242,7 +238,8 @@ class CrawlStore:
await cursor.close()
for peer in peers:
cursor = await self.crawl_db.execute(
"INSERT OR REPLACE INTO good_peers VALUES(?)", (peer,),
"INSERT OR REPLACE INTO good_peers VALUES(?)",
(peer,),
)
await cursor.close()
await self.crawl_db.commit()
......@@ -205,7 +205,6 @@ class Crawler:
def _close(self):
self._shut_down = True
self.transport.close()
async def _await_closed(self):
await self.connection.close()
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment