moonstream-to
Python client silently allows creating dupe subscription
The Python client (and possibly the backend) will silently accept a duplicate subscription (same label, color, address, etc.). I ran my code twice and ran list_subscriptions() afterward, and saw this in the log -- note that "load_uniswap_trades" appears twice.
As I want to create subscriptions on-the-fly during our load jobs this is a bit dangerous. It would be better to fail fast.
2021-11-11 15:06:13 - dagster - INFO - load_uniswap_trades_job - 03c9bb6f-983b-419d-8ee9-22556c49a7de - load_trades - {'subscriptions': [{'id': 'b4725a99-299e-4c16-9bbe-73879dabf944', 'address': '0x7a250d5630B4cF539739dF2C5dAcb4c659F2488D', 'color': '#389724', 'label': 'Address', 'user_id': '62e5a57c-b480-4bf6-b501-fcf3522520db', 'subscription_type_id': 'ethereum_blockchain', 'created_at': '2021-11-11T16:19:23.676294+00:00', 'updated_at': '2021-11-11T16:19:23.676294+00:00'}, {'id': '34b2aa64-eb18-4080-bacf-6a627e4bb408', 'address': '0x7a250d5630B4cF539739dF2C5dAcb4c659F2488D', 'color': '#389724', 'label': 'load_uniswap_trades', 'user_id': '62e5a57c-b480-4bf6-b501-fcf3522520db', 'subscription_type_id': 'ethereum_blockchain', 'created_at': '2021-11-11T20:05:41.047392+00:00', 'updated_at': '2021-11-11T20:05:41.047392+00:00'}, {'id': 'ace9a117-2715-45fc-a44f-c918295da74d', 'address': '0x7a250d5630B4cF539739dF2C5dAcb4c659F2488D', 'color': '#389724', 'label': 'load_uniswap_trades', 'user_id': '62e5a57c-b480-4bf6-b501-fcf3522520db', 'subscription_type_id': 'ethereum_blockchain', 'created_at': '2021-11-11T20:06:12.906733+00:00', 'updated_at': '2021-11-11T20:06:12.906733+00:00'}]}
