clean_digital_value.job() - Code Metrics - myems/myems-cleaning - Measure and Improve Code Quality continuously with Scrutinizer

clean_digital_value.job() B
last analyzed 2020-12-23 04:08 UTC

↳ Parent: clean_digital_value

Complexity

Conditions

Size

Total Lines	28
Code Lines	24

Duplication

Lines	28
Ratio	100 %

Importance

Changes

Metric	Value
cc	7
eloc	24
nop	1
dl	28
loc	28
rs	7.904
c	0
b	0
f	0

import mysql.connector
import config
import time
from datetime import datetime, timedelta
import schedule


def job(logger):


    cnx = None
    cursor = None
    try:
        cnx = mysql.connector.connect(**config.myems_historical_db)
        cursor = cnx.cursor()
    except Exception as e:
        logger.error("Error in clean digital value process " + str(e))
        if cursor:
            cursor.close()
        if cnx:
            cnx.close()
        return

    expired_utc = datetime.utcnow() - timedelta(days=config.live_in_days)
    try:
        cursor.execute(" DELETE FROM tbl_digital_value WHERE utc_date_time < %s ", (expired_utc,))
        cnx.commit()
    except Exception as e:
        logger.error("Error in delete_expired_trend process " + str(e))
    finally:
        if cursor:
            cursor.close()
        if cnx:
            cnx.close()

    logger.info("Deleted trend before date time in UTC: " + expired_utc.isoformat()[0:19])


def process(logger):

    if config.is_debug:
        # run the job immediately
        job(logger)
        return

    schedule.every(8).hours.do(job, logger)

    while True:
        schedule.run_pending()
        time.sleep(60)



1		import mysql.connector
2		import config
3		import time
4		from datetime import datetime, timedelta
5		import schedule
6
7
8	View Code Duplication	def job(logger):
		0 ignored issues – show Duplication introduced 2020-11-25 02:12 UTC by Report Bug Copy Issue Report This code seems to be duplicated in your project. Loading history...
9
10		cnx = None
11		cursor = None
12		try:
13		cnx = mysql.connector.connect(**config.myems_historical_db)
14		cursor = cnx.cursor()
15		except Exception as e:
16		logger.error("Error in clean digital value process " + str(e))
17		if cursor:
18		cursor.close()
19		if cnx:
20		cnx.close()
21		return
22
23		expired_utc = datetime.utcnow() - timedelta(days=config.live_in_days)
24		try:
25		cursor.execute(" DELETE FROM tbl_digital_value WHERE utc_date_time < %s ", (expired_utc,))
26		cnx.commit()
27		except Exception as e:
28		logger.error("Error in delete_expired_trend process " + str(e))
29		finally:
30		if cursor:
31		cursor.close()
32		if cnx:
33		cnx.close()
34
35		logger.info("Deleted trend before date time in UTC: " + expired_utc.isoformat()[0:19])
36
37
38		def process(logger):
39
40		if config.is_debug:
41		# run the job immediately
42		job(logger)
43		return
44
45		schedule.every(8).hours.do(job, logger)
46
47		while True:
48		schedule.run_pending()
49		time.sleep(60)
50
51

myems / myems-cleaning

clean_digital_value.job() B last analyzed 2020-12-23 04:08 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

clean_digital_value.job() B
last analyzed 2020-12-23 04:08 UTC