(self, user, tags, type, productId)
| 304 | mon.close() |
| 305 | |
| 306 | def startprocess(self, user, tags, type, productId): |
| 307 | try: |
| 308 | self._processstart(user=user, tags=tags, productId=productId) |
| 309 | while True: |
| 310 | # therad = theradPorcess(user=user, tags=tags, type=type) |
| 311 | # therad.start() |
| 312 | hashtags(user=user, tags=tags, type=type, productId=productId) |
| 313 | check = self._dbProcessReader(user=user, tags=tags, productId=productId) |
| 314 | print(check) |
| 315 | if check == False: |
| 316 | break |
| 317 | time.sleep(300) |
| 318 | # therad.join() |
| 319 | except Exception as err: |
| 320 | print(f"exception : {err}\n") |
| 321 | print("error::startPoress::>>", sys.exc_info()[1]) |
| 322 | |
| 323 | def deletProcess(self, user, tags, productId): |
| 324 | mon = pymongo.MongoClient(host=config.host, port=config.mongoPort) |
no test coverage detected