Merge pull request #5 from nodestream-proj/fix/migrations

Fix improper use of query object in migrator

Author: zprobst

nodestream_plugin_neo4j/migrator.py

@@ -167,9 +167,10 @@ async def mark_migration_as_executed(self, migration: Migration) -> None:
         await self.database_connection.execute(query)
 
     async def get_completed_migrations(self, graph: MigrationGraph) -> List[Migration]:
+        query = Query.from_statement(LIST_MIGRATIONS_QUERY)
         return [
             graph.get_migration(record["name"])
-            for record in await self.database_connection.execute(LIST_MIGRATIONS_QUERY)
+            for record in await self.database_connection.execute(query)
         ]
 
     async def execute_create_node_type(self, operation: CreateNodeType) -> None: