@gen.coroutine
  def _CreateNewEpisodesAndPosts(self, new_ep_dicts, new_ids):
    tasks = []
    for new_ep_dict in deepcopy(new_ep_dicts):
      ep_id = new_ep_dict['episode_id']
      ph_ids = [ph_id for ph_id in new_ep_dict.pop('photo_ids')
                if Post.ConstructPostId(ep_id, ph_id) in new_ids]

      if ep_id in new_ids:
        tasks.append(gen.Task(Episode.CreateNew, self._client, **new_ep_dict))

      for ph_id in ph_ids:
        post = Post.CreateFromKeywords(episode_id=ep_id, photo_id=ph_id)
        post.labels.remove(Post.UNSHARED)
        post.labels.remove(Post.REMOVED)
        tasks.append(gen.Task(post.Update, self._client))

    yield tasks
Execute the query string, with optional parameters.
dataset/ETHPy150Open viewfinderco/viewfinder/backend/op/viewfinder_op.py/ViewfinderOperation._CreateNewEpisodesAndPosts--crossover with--dataset/ETHPy150Open harryliu/edwin/edwinServer/site_packages/pypyodbc.py/Cursor.execute