#NEWLINE# def start_product_update( profile_id , tiids_to_update , priority ) : #NEWLINE# #INDENT# myredis = tiredis . from_url ( os . getenv ( 'REDIS_URL' ) , db = tiredis . REDIS_MAIN_DATABASE_NUMBER ) #NEWLINE# for tiid in tiids_to_update : #NEWLINE# #INDENT# myredis . clear_provider_task_ids ( tiid ) #NEWLINE# myredis . set_provider_task_ids ( tiid , [ 'STARTED' ] ) #NEWLINE# #UNINDENT# from core_tasks import put_on_celery_queue #NEWLINE# put_on_celery_queue ( profile_id , tiids_to_update , priority ) #NEWLINE# return