import time
from celery import shared_task
from app import db
from models import *


@shared_task(ignore_result=False)
def sendNotification(notificationID, users, level):
    notification = db.session.get(Notification, notificationID)

    for user in users:
        db.session.add(UserNotification(db.session.get(User, user), notification, level))
    db.session.commit()

    return 0                    # notification sent successfully