#NEWLINE# @ shared_task ( name = 'nodeconductor.openstack.extend_disk' ) #NEWLINE# def extend_disk( instance_uuid , disk_size ) : #NEWLINE# #INDENT# extend_instance_disk . apply_async ( args = ( instance_uuid , disk_size ) , link = disk_extension_succeeded . si ( instance_uuid , disk_size ) , link_error = disk_extension_failed . si ( instance_uuid , disk_size ) )