move celery task start to manage command

app_core/management/commands/start_block_monitor.py

@@ -0,0 +1,21 @@
+from django.core.management.base import BaseCommand, CommandError
+
+from ethereum_scanner.celery import set_web3_filter_task
+
+
+class Command(BaseCommand):
+    help = 'Sync local database with blockchain from current position to end block'
+
+    def add_arguments(self, parser):
+        parser.add_argument('async', nargs='?', default='async')
+
+    # TODO logger - synced
+    def handle(self, *args, **options):
+
+        async_start = options['async']
+        if async_start is 'async':
+            set_web3_filter_task.delay()
+            self.stdout.write(self.style.SUCCESS('Successfully sync started'))
+        else:
+            set_web3_filter_task()
+            self.stdout.write(self.style.SUCCESS('Successfully synced'))

ethereum_scanner/celery.py

@@ -44,4 +44,3 @@ def sync_blocks_from_position_to_end():
 
 if __name__ == '__main__':
     app.start()
-    set_web3_filter_task.delay()