code: def is_reassignment_pending(self):
          
          in_progress_plan = self.zk.get_pending_plan()
          if in_progress_plan:
              in_progress_partitions = in_progress_plan['partitions']
              self.log.info(
                  'Previous re-assignment in progress for {count} partitions.'
                  ' Current partitions in re-assignment queue: {partitions}'
                  .format(
                      count=len(in_progress_partitions),
                      partitions=in_progress_partitions,
                  )
              )
              return True
          else:
              return False
docs: Return True if there are reassignment tasks pending.