boards/management/commands/fetch_from_sources.py

from django.core.management import BaseCommand
from django.db import transaction

from boards.models.source import ThreadSource

__author__ = 'neko259'


class Command(BaseCommand):
    help = 'Fetches data from sources and posts into appropriate threads'

    @transaction.atomic
    def handle(self, *args, **options):
        for source in ThreadSource.objects.all():
            source.fetch_latest_posts()