in services/data/postgres_async_db.py [0:0]
def __init__(self, name='global'):
self.name = name
self.logger = logging.getLogger("AsyncPostgresDB:{name}".format(name=self.name))
tables = []
self.flow_table_postgres = AsyncFlowTablePostgres(self)
self.run_table_postgres = AsyncRunTablePostgres(self)
self.step_table_postgres = AsyncStepTablePostgres(self)
self.task_table_postgres = AsyncTaskTablePostgres(self)
self.artifact_table_postgres = AsyncArtifactTablePostgres(self)
self.metadata_table_postgres = AsyncMetadataTablePostgres(self)
tables.append(self.flow_table_postgres)
tables.append(self.run_table_postgres)
tables.append(self.step_table_postgres)
tables.append(self.task_table_postgres)
tables.append(self.artifact_table_postgres)
tables.append(self.metadata_table_postgres)
self.tables = tables