import json
import logging
import os
import subprocess

from celery import Celery
from celery.schedules import crontab

from .targets.facebook_messenger import Post as MessengerPost
from .targets.twitter import Post as TwitterPost
import whistleblower.queue

HOUR = 3600
ENABLED_TARGETS = [
    TwitterPost,
    MessengerPost,
]
RABBITMQ_URL = os.environ.get('CLOUDAMQP_URL', 'pyamqp://guest@localhost//')
app = Celery('tasks', broker=RABBITMQ_URL)


@app.on_after_configure.connect
def setup_periodic_tasks(sender, **kwargs):
    sender.add_periodic_task(4 * HOUR, process_queue.s())


@app.task
def update_suspicions_dataset():
    command = ['python', 'rosie/rosie.py', 'run',
               'chamber_of_deputies', 'data', '--years=2017,2016']
    subprocess.run(command, check=True)


@app.task
def update_queue():
    whistleblower.queue.Queue().update()


@app.task
def process_queue():
    whistleblower.queue.Queue().process()


@app.task
def publish_reimbursement(reimbursement):
    for target in ENABLED_TARGETS:
        target(reimbursement).publish()

import json
import logging
import os
import subprocess

from celery import Celery
from celery.schedules import crontab

from .targets.facebook_messenger import Post as MessengerPost
from .targets.twitter import Post as TwitterPost
import whistleblower.queue

HOUR = 3600
ENABLED_TARGETS = [
    TwitterPost,
    MessengerPost,
]
RABBITMQ_URL = os.environ.get('CLOUDAMQP_URL', 'pyamqp://guest@localhost//')
app = Celery('tasks', broker=RABBITMQ_URL)


@app.on_after_configure.connect
def setup_periodic_tasks(sender, **kwargs):
    sender.add_periodic_task(4 * HOUR, process_queue.s())


@app.task
def update_queue():
    whistleblower.queue.Queue().update()


@app.task
def process_queue():
    whistleblower.queue.Queue().process()


@app.task
def publish_reimbursement(reimbursement):
    for target in ENABLED_TARGETS:
        target(reimbursement).publish()

Remove task for updating data
Remove task for updating data

Not sure if this is the best method to have it.
Since for now is not needed, droping it from the codebase.

  import json
  import logging
  import os
  import subprocess
  
  from celery import Celery
  from celery.schedules import crontab
  
  from .targets.facebook_messenger import Post as MessengerPost
  from .targets.twitter import Post as TwitterPost
  import whistleblower.queue
  
  HOUR = 3600
  ENABLED_TARGETS = [
      TwitterPost,
      MessengerPost,
  ]
  RABBITMQ_URL = os.environ.get('CLOUDAMQP_URL', 'pyamqp://guest@localhost//')
  app = Celery('tasks', broker=RABBITMQ_URL)
  
  
  @app.on_after_configure.connect
  def setup_periodic_tasks(sender, **kwargs):
      sender.add_periodic_task(4 * HOUR, process_queue.s())
  
  
  @app.task
- def update_suspicions_dataset():
-     command = ['python', 'rosie/rosie.py', 'run',
-                'chamber_of_deputies', 'data', '--years=2017,2016']
-     subprocess.run(command, check=True)
- 
- 
- @app.task
  def update_queue():
      whistleblower.queue.Queue().update()
  
  
  @app.task
  def process_queue():
      whistleblower.queue.Queue().process()
  
  
  @app.task
  def publish_reimbursement(reimbursement):
      for target in ENABLED_TARGETS:
          target(reimbursement).publish()
  
Remove task for updating data
## Code Before:
import json
import logging
import os
import subprocess

from celery import Celery
from celery.schedules import crontab

from .targets.facebook_messenger import Post as MessengerPost
from .targets.twitter import Post as TwitterPost
import whistleblower.queue

HOUR = 3600
ENABLED_TARGETS = [
    TwitterPost,
    MessengerPost,
]
RABBITMQ_URL = os.environ.get('CLOUDAMQP_URL', 'pyamqp://guest@localhost//')
app = Celery('tasks', broker=RABBITMQ_URL)


@app.on_after_configure.connect
def setup_periodic_tasks(sender, **kwargs):
    sender.add_periodic_task(4 * HOUR, process_queue.s())


@app.task
def update_suspicions_dataset():
    command = ['python', 'rosie/rosie.py', 'run',
               'chamber_of_deputies', 'data', '--years=2017,2016']
    subprocess.run(command, check=True)


@app.task
def update_queue():
    whistleblower.queue.Queue().update()


@app.task
def process_queue():
    whistleblower.queue.Queue().process()


@app.task
def publish_reimbursement(reimbursement):
    for target in ENABLED_TARGETS:
        target(reimbursement).publish()

## Instruction:
Remove task for updating data
## Code After:
import json
import logging
import os
import subprocess

from celery import Celery
from celery.schedules import crontab

from .targets.facebook_messenger import Post as MessengerPost
from .targets.twitter import Post as TwitterPost
import whistleblower.queue

HOUR = 3600
ENABLED_TARGETS = [
    TwitterPost,
    MessengerPost,
]
RABBITMQ_URL = os.environ.get('CLOUDAMQP_URL', 'pyamqp://guest@localhost//')
app = Celery('tasks', broker=RABBITMQ_URL)


@app.on_after_configure.connect
def setup_periodic_tasks(sender, **kwargs):
    sender.add_periodic_task(4 * HOUR, process_queue.s())


@app.task
def update_queue():
    whistleblower.queue.Queue().update()


@app.task
def process_queue():
    whistleblower.queue.Queue().process()


@app.task
def publish_reimbursement(reimbursement):
    for target in ENABLED_TARGETS:
        target(reimbursement).publish()
