@receiver(SignalHandler.course_published)
def trigger_update_xblocks_cache_task(sender, course_key, **kwargs):
 tasks = import_module('openedx.core.djangoapps.bookmarks.tasks')
 tasks.update_xblocks_cache.apply_async([unicode(course_key)], countdown=0)

@ receiver ( SignalHandler . course_published ) def trigger_update_xblocks_cache_task ( sender , course_key , ** kwargs ) : tasks = import_module ( 'openedx.core.djangoapps.bookmarks.tasks' ) tasks . update_xblocks_cache . apply_async ( [ unicode ( course_key ) ] , countdown = 0 )
trigger update_xblocks_cache() when course_published signal is fired .