From 288d0576b9b1ab2275b1e0ecf00c581a72cb036c Mon Sep 17 00:00:00 2001 From: Sourabh Gandhi Date: Mon, 9 Dec 2024 04:50:56 +0000 Subject: [PATCH] Remove redundant code --- tap_mongodb/sync_strategies/oplog.py | 4 ---- tests/test_mongodb_oplog_transaction.py | 23 ----------------------- 2 files changed, 27 deletions(-) diff --git a/tap_mongodb/sync_strategies/oplog.py b/tap_mongodb/sync_strategies/oplog.py index 9cc6a75..1aa1163 100644 --- a/tap_mongodb/sync_strategies/oplog.py +++ b/tap_mongodb/sync_strategies/oplog.py @@ -8,10 +8,6 @@ from bson import timestamp import tap_mongodb.sync_strategies.common as common -from debugpy import listen, wait_for_client -listen(8000) -wait_for_client() - LOGGER = singer.get_logger() SDC_DELETED_AT = "_sdc_deleted_at" diff --git a/tests/test_mongodb_oplog_transaction.py b/tests/test_mongodb_oplog_transaction.py index 6f3e59d..b27a28d 100644 --- a/tests/test_mongodb_oplog_transaction.py +++ b/tests/test_mongodb_oplog_transaction.py @@ -2,37 +2,14 @@ import tap_tester.menagerie as menagerie import tap_tester.runner as runner import os -import datetime import unittest -import datetime -import pymongo import string import random -import time -import re -import pprint -import pdb -import bson -from bson import ObjectId -import singer -from functools import reduce -from singer import utils, metadata from mongodb_common import drop_all_collections, get_test_connection -import decimal RECORD_COUNT = {} -# def get_test_connection(): -# username = os.getenv('TAP_MONGODB_USER') -# password = os.getenv('TAP_MONGODB_PASSWORD') -# host= os.getenv('TAP_MONGODB_HOST') -# auth_source = os.getenv('TAP_MONGODB_DBNAME') -# port = os.getenv('TAP_MONGODB_PORT') -# ssl = False -# conn = pymongo.MongoClient(host=host, username=username, password=password, port=port, authSource=auth_source, ssl=ssl) -# return conn - def random_string_generator(size=6, chars=string.ascii_uppercase + string.digits): return ''.join(random.choice(chars) for x in range(size))