Programmiererforum

Code: Select all

engine = create_engine(app.config['SQLALCHEMY_DATABASE_URI'])
Base.metadata.bind = engineDBSession = sessionmaker(bind=engine)

@app.cli.command("generate_task_notifications")
def createTaskNotification(): # Run scheduled job for creating task
statuses.print('starting jobs')
generate_task_notifications()
print('scheduled jobs executed at '+ str(datetime.now()))
return

def generate_task_notifications():
session = DBSession()
upcoming_days_upto = int(session.query(SystemConfig).filter(SystemConfig.Key == e_SysConfig.UpcomingDay.Key).first().Value)
session.close()
return upcoming_days_upto