code: def __init__(self, collection, pipline=None):
      self.collection = collection
      self.pipeline = []
  
      if pipline is None:
          pipline = []
      for step in pipline:
          self.add_step(step)
  
file_path: mindsdb/mindsdb/api/mongo/utilities/mongodb_query.py
imports: import datetime
  from json import JSONEncoder
  from bson import ObjectId
label_desc: Use image node_id 1 to create a new MongoQuery object  with example: obj = MongoQuery(collection, pipline)