Infinidat/infi.clickhouse_orm
1
1
Fork 0
mirror of https://github.com/Infinidat/infi.clickhouse_orm.git synced 2025-08-02 19:20:14 +03:00
Code Issues Packages Projects Releases Wiki Activity

Chore: fix linting on database.py

Browse Source
This commit is contained in:
olliemath 2021-07-27 22:58:22 +01:00
parent 13655da35d
commit cfdf2fd389
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
clickhouse_orm/database.py
View File

@ -4,7 +4,7 @@ import re
import requests import requests
from collections import namedtuple from collections import namedtuple
from .models import ModelBase from .models import ModelBase
from .utils import escape, parse_tsv, import_submodules from .utils import parse_tsv, import_submodules
from math import ceil from math import ceil
import datetime import datetime
from string import Template from string import Template
@ -107,7 +107,7 @@ class Database(object):
self.request_session.auth = (username, password or '') self.request_session.auth = (username, password or '')
self.log_statements = log_statements self.log_statements = log_statements
self.settings = {} self.settings = {}
self.db_exists = False # this is required before running _is_existing_database self.db_exists = False # this is required before running _is_existing_database
self.db_exists = self._is_existing_database() self.db_exists = self._is_existing_database()
if readonly: if readonly:
if not self.db_exists: if not self.db_exists:
@ -144,7 +144,7 @@ class Database(object):
''' '''
if model_class.is_system_model(): if model_class.is_system_model():
raise DatabaseException("You can't create system table") raise DatabaseException("You can't create system table")
if getattr(model_class, 'engine') is None: if model_class.engine is None:
raise DatabaseException("%s class must define an engine" % model_class.__name__) raise DatabaseException("%s class must define an engine" % model_class.__name__)
self._send(model_class.create_table_sql(self)) self._send(model_class.create_table_sql(self))