(self, mongo_connector, job_name, log_level=None)
| 63 | return logging.getLogger(__name__) |
| 64 | |
| 65 | def __init__(self, mongo_connector, job_name, log_level=None): |
| 66 | self._logger = self._log() |
| 67 | if log_level is not None: |
| 68 | self._logger.setLevel(log_level) |
| 69 | |
| 70 | self._mongo_connector = mongo_connector |
| 71 | self._jobs_collection = mongo_connector.get_jobs_connection() |
| 72 | self._job_name = job_name |
| 73 | |
| 74 | def __check_job_exists(self, job_name): |
| 75 | """ |
nothing calls this directly
no test coverage detected