from __future__ import absolute_import

from celery import shared_task

from datastore.models import Project


@shared_task
def run_meter(project_pk):
    project = Project.objects.get(pk=project_pk):
    project.run_meter()

Add run meter task