Subversion Repositories SmartDukaan

Rev

Rev 13493 | Rev 13726 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 13493 Rev 13520
Line 508... Line 508...
508 
        ItemAvailabilityCache.query.filter(ItemAvailabilityCache.itemId.in_(item_id)).delete(synchronize_session='fetch')
 508 
        ItemAvailabilityCache.query.filter(ItemAvailabilityCache.itemId.in_(item_id)).delete(synchronize_session='fetch')
509 
        session.commit()
 509 
        session.commit()
510 
        t = threading.Thread(target=_task_update_item_availability_cache, args=(item_id,))
 510 
        t = threading.Thread(target=_task_update_item_availability_cache, args=(item_id,))
511 
        t.start()
 511 
        t.start()
512 
 
 512 
 
513 
    if item_id:
 513 
    elif item_id:
514 
        ItemAvailabilityCache.query.filter_by(itemId = item_id).delete()
 514 
        ItemAvailabilityCache.query.filter_by(itemId = item_id).delete()
515 
        session.commit()
 515 
        session.commit()
516
516
517 
def _task_update_item_availability_cache(item_ids):
 517 
def _task_update_item_availability_cache(item_ids):
518 
    client = CatalogClient("catalog_service_server_host_master", "catalog_service_server_port").get_client()
 518 
    client = CatalogClient("catalog_service_server_host_master", "catalog_service_server_port").get_client()