docs: def run(self):
          """Compute and store inflation-adjusted movie budgets
          """
          self.mark_incomplete()
          session = client.get_client().create_session()
  
          # load CPI data
          cpi = ConsumerPriceIndexFile().load()
  
          # max year we have CPI data for
          max_cpi_year = cpi['Year'].max()
  
          # extract annual average only, index by year
          cpi = cpi.set_index('Year')['Annual']
  
          # process all movies
          for movie in session.query(models.Movie).all():
              # we can only compute an inflation-adjusted budget if we know the year and budget
              if movie.year is not None and movie.budget is not None:
                  if movie.year > max_cpi_year:
                      # if movie is too new, don't inflation-adjust
                      movie.budget_inflation_adjusted = movie.budget
                  else:
                      movie.budget_inflation_adjusted = movie.budget * cpi.loc[max_cpi_year] / cpi.loc[movie.year]
  
          # done, save all data, finalize task
          session.commit()
          session.close()
          self.mark_complete()