from __future__ import absolute_import, unicode_literals

from atlas.celerybackend.celery import app
from atlas.prestage.views import find_action_to_execute, submit_all_tapes_processed
from atlas.prodtask.hashtag import hashtag_request_to_tasks
from atlas.prodtask.mcevgen import sync_cvmfs_db
from atlas.prodtask.open_ended import check_open_ended
from atlas.prodtask.task_views import sync_old_tasks

import logging
_logger = logging.getLogger('prodtaskwebui')


@app.task
def test_celery():
    _logger.info('test celery')
    return 2

@app.task(ignore_result=True)
def sync_tasks():
    sync_old_tasks(-1)
    return None


@app.task(ignore_result=True)
def step_actions():
    find_action_to_execute()
    return None

@app.task(ignore_result=True)
def data_carousel():
    submit_all_tapes_processed()
    return None


@app.task(ignore_result=True)
def open_ended():
    check_open_ended()
    return None


@app.task(ignore_result=True)
def request_hashtags():
    hashtag_request_to_tasks()
    return None


@app.task(ignore_result=True)
def sync_evgen_jo():
    sync_cvmfs_db()
    return None

from __future__ import absolute_import, unicode_literals

from atlas.celerybackend.celery import app
from atlas.prestage.views import find_action_to_execute, submit_all_tapes_processed, delete_done_staging_rules
from atlas.prodtask.hashtag import hashtag_request_to_tasks
from atlas.prodtask.mcevgen import sync_cvmfs_db
from atlas.prodtask.open_ended import check_open_ended
from atlas.prodtask.task_views import sync_old_tasks

import logging
_logger = logging.getLogger('prodtaskwebui')


@app.task
def test_celery():
    _logger.info('test celery')
    return 2

@app.task(ignore_result=True)
def sync_tasks():
    sync_old_tasks(-1)
    return None


@app.task(ignore_result=True)
def step_actions():
    find_action_to_execute()
    return None

@app.task(ignore_result=True)
def data_carousel():
    submit_all_tapes_processed()
    return None


@app.task(ignore_result=True)
def open_ended():
    check_open_ended()
    return None


@app.task(ignore_result=True)
def request_hashtags():
    hashtag_request_to_tasks()
    return None


@app.task(ignore_result=True)
def sync_evgen_jo():
    sync_cvmfs_db()
    return None

@app.task(ignore_result=True)
def remove_done_staging(production_requests):
    delete_done_staging_rules(production_requests)
    return None
Add remove done staged rules
Add remove done staged rules

  from __future__ import absolute_import, unicode_literals
  
  from atlas.celerybackend.celery import app
- from atlas.prestage.views import find_action_to_execute, submit_all_tapes_processed
+ from atlas.prestage.views import find_action_to_execute, submit_all_tapes_processed, delete_done_staging_rules
  from atlas.prodtask.hashtag import hashtag_request_to_tasks
  from atlas.prodtask.mcevgen import sync_cvmfs_db
  from atlas.prodtask.open_ended import check_open_ended
  from atlas.prodtask.task_views import sync_old_tasks
  
  import logging
  _logger = logging.getLogger('prodtaskwebui')
  
  
  @app.task
  def test_celery():
      _logger.info('test celery')
      return 2
  
  @app.task(ignore_result=True)
  def sync_tasks():
      sync_old_tasks(-1)
      return None
  
  
  @app.task(ignore_result=True)
  def step_actions():
      find_action_to_execute()
      return None
  
  @app.task(ignore_result=True)
  def data_carousel():
      submit_all_tapes_processed()
      return None
  
  
  @app.task(ignore_result=True)
  def open_ended():
      check_open_ended()
      return None
  
  
  @app.task(ignore_result=True)
  def request_hashtags():
      hashtag_request_to_tasks()
      return None
  
  
  @app.task(ignore_result=True)
  def sync_evgen_jo():
      sync_cvmfs_db()
      return None
  
+ @app.task(ignore_result=True)
+ def remove_done_staging(production_requests):
+     delete_done_staging_rules(production_requests)
+     return None
Add remove done staged rules
## Code Before:
from __future__ import absolute_import, unicode_literals

from atlas.celerybackend.celery import app
from atlas.prestage.views import find_action_to_execute, submit_all_tapes_processed
from atlas.prodtask.hashtag import hashtag_request_to_tasks
from atlas.prodtask.mcevgen import sync_cvmfs_db
from atlas.prodtask.open_ended import check_open_ended
from atlas.prodtask.task_views import sync_old_tasks

import logging
_logger = logging.getLogger('prodtaskwebui')


@app.task
def test_celery():
    _logger.info('test celery')
    return 2

@app.task(ignore_result=True)
def sync_tasks():
    sync_old_tasks(-1)
    return None


@app.task(ignore_result=True)
def step_actions():
    find_action_to_execute()
    return None

@app.task(ignore_result=True)
def data_carousel():
    submit_all_tapes_processed()
    return None


@app.task(ignore_result=True)
def open_ended():
    check_open_ended()
    return None


@app.task(ignore_result=True)
def request_hashtags():
    hashtag_request_to_tasks()
    return None


@app.task(ignore_result=True)
def sync_evgen_jo():
    sync_cvmfs_db()
    return None

## Instruction:
Add remove done staged rules
## Code After:
from __future__ import absolute_import, unicode_literals

from atlas.celerybackend.celery import app
from atlas.prestage.views import find_action_to_execute, submit_all_tapes_processed, delete_done_staging_rules
from atlas.prodtask.hashtag import hashtag_request_to_tasks
from atlas.prodtask.mcevgen import sync_cvmfs_db
from atlas.prodtask.open_ended import check_open_ended
from atlas.prodtask.task_views import sync_old_tasks

import logging
_logger = logging.getLogger('prodtaskwebui')


@app.task
def test_celery():
    _logger.info('test celery')
    return 2

@app.task(ignore_result=True)
def sync_tasks():
    sync_old_tasks(-1)
    return None


@app.task(ignore_result=True)
def step_actions():
    find_action_to_execute()
    return None

@app.task(ignore_result=True)
def data_carousel():
    submit_all_tapes_processed()
    return None


@app.task(ignore_result=True)
def open_ended():
    check_open_ended()
    return None


@app.task(ignore_result=True)
def request_hashtags():
    hashtag_request_to_tasks()
    return None


@app.task(ignore_result=True)
def sync_evgen_jo():
    sync_cvmfs_db()
    return None

@app.task(ignore_result=True)
def remove_done_staging(production_requests):
    delete_done_staging_rules(production_requests)
    return None