Function handle_meta_task_pulling 

fn handle_meta_task_pulling(
    pull_task_ack: &mut bool,
    task_queue: &IcebergTaskQueue,
    max_task_parallelism: u32,
    max_pull_task_count: u32,
    request_sender: &UnboundedSender<SubscribeIcebergCompactionEventRequest>,
) -> bool

Handle pulling new tasks from meta service Returns true if the stream should be restarted