Fix various broken symbols
This commit is contained in:
parent
1e09e93400
commit
ff7da8b8a2
1 changed files with 2 additions and 2 deletions
|
@ -172,7 +172,6 @@ as t(time bigint, name varchar, avg double precision);
|
||||||
@staticmethod
|
@staticmethod
|
||||||
def init_db(verbose):
|
def init_db(verbose):
|
||||||
import sqlalchemy as db
|
import sqlalchemy as db
|
||||||
_verbose = False #True
|
|
||||||
engine = db.create_engine('postgresql://hpc@hawk-monitor4:5432/coe_mon', echo=verbose)
|
engine = db.create_engine('postgresql://hpc@hawk-monitor4:5432/coe_mon', echo=verbose)
|
||||||
connection = engine.connect()
|
connection = engine.connect()
|
||||||
return connection
|
return connection
|
||||||
|
@ -193,7 +192,8 @@ as t(time bigint, name varchar, avg double precision);
|
||||||
query = self.build_query(jobid, interval, hawk_ai)
|
query = self.build_query(jobid, interval, hawk_ai)
|
||||||
return self.connection.execute(query).fetchall()
|
return self.connection.execute(query).fetchall()
|
||||||
|
|
||||||
def db_to_pf(self, jobid, intrval, hawk_ai):
|
def db_to_pf(self, jobid, interval, hawk_ai):
|
||||||
|
import pandas as pd
|
||||||
query = self.build_query(jobid, interval, hawk_ai)
|
query = self.build_query(jobid, interval, hawk_ai)
|
||||||
return pd.read_sql(query, con=self.connection)
|
return pd.read_sql(query, con=self.connection)
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue