diff options
Diffstat (limited to 'python/api_quotes/quotes.py')
| -rw-r--r-- | python/api_quotes/quotes.py | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/python/api_quotes/quotes.py b/python/api_quotes/quotes.py index fd5d1c2e..8d0b0231 100644 --- a/python/api_quotes/quotes.py +++ b/python/api_quotes/quotes.py @@ -53,6 +53,12 @@ class MarkitQuote(Deal, table_name=None, deal_type=None): def clear(cls): cls._insert_queue.clear() + @classmethod + def already_uploaded(cls): + with cls._conn.cursor() as c: + c.execute(f"SELECT distinct msg_id as msg_id FROM {cls._table_name}") + return set(row.msg_id for row in c) + # TODO # @property # def message(self): |