could not assemble any primary key columns for mapped table

_as_declarative(cls, classname, cls._dict_)įile '/usr/local/lib/python3.6/site-packages/sqlalchemy/ext/declarative/base.py', line 131, in _as_declarative Table_class = create_table_class(Table(name, metadata, autoload=True))įile '/usr/local/lib/python3.6/site-packages/beam_nuggets/io/relational_db_api.py', line 420, in create_table_classįile '/usr/local/lib/python3.6/site-packages/sqlalchemy/ext/declarative/api.py', line 75, in _init_ Table_class = get_table_f(self._session, name, **get_table_f_params)įile '/usr/local/lib/python3.6/site-packages/beam_nuggets/io/relational_db_api.py', line 382, in load_table Self._get_table(name, get_table_f, **get_table_f_params)įile '/usr/local/lib/python3.6/site-packages/beam_nuggets/io/relational_db_api.py', line 325, in _get_table Table = self._open_table_for_read(table_name)įile '/usr/local/lib/python3.6/site-packages/beam_nuggets/io/relational_db_api.py', line 304, in _open_table_for_readįile '/usr/local/lib/python3.6/site-packages/beam_nuggets/io/relational_db_api.py', line 319, in _open_table

File 'apache_beam/runners/common.py', line 780, in apache_.processįile 'apache_beam/runners/common.py', line 440, in apache_.invoke_processįile 'apache_beam/runners/common.py', line 895, in apache_._OutputProcessor.process_outputsįile '/usr/local/lib/python3.6/site-packages/beam_nuggets/io/relational_db.py', line 96, in processįor record in db.query(table_name, query):įile '/usr/local/lib/python3.6/site-packages/beam_nuggets/io/relational_db_api.py', line 269, in query

Could not assemble any primary key columns for mapped table