code: def timeline_operator(pkl_path: str, input_table_spec: TableSpec):
      """Loads a pandas parquet, converts to pyspark, and uploads df to Hive.
      Then call the timeline operator.
      """
  
      pd_df = pd.read_pickle(pkl_path)
      spark = get_spark_session()
      df = spark.createDataFrame(pd_df)
      input_name = f"{input_table_spec.table_name}{PRE_TIMELINE_SUFFIX}"
      df.createTempView(input_name)
  
      output_name = input_table_spec.table_name
      include_possible_actions = "possible_actions" in pd_df
      arg = {
          "startDs": "2019-01-01",
          "endDs": "2019-01-01",
          "addTerminalStateRow": True,
          "inputTableName": input_name,
          "outputTableName": output_name,
          "includePossibleActions": include_possible_actions,
          "percentileFunction": "percentile_approx",
          "rewardColumns": ["reward", "metrics"],
          "extraFeatureColumns": [],
      }
      call_spark_class(
          spark, class_name="Timeline", args=json.dumps(arg)
      )
  
imports: import json
  import logging
  from typing import Optional
  import gym
  import numpy
  import pandas
  import pytorch_lightning
  import torch
  from reagent.data.spark_utils import call_spark_class, get_spark_session
  from reagent.gym.agents.agent import Agent
  from reagent.gym.envs import Gym
  from reagent.gym.policies.predictor_policies import create_predictor_policy_from_model
  from reagent.gym.policies.random_policies import make_random_policy_for_env
  from reagent.gym.runners.gymrunner import evaluate_for_n_episodes
  from reagent.gym.utils import fill_replay_buffer
  from reagent.model_managers.union import ModelManager__Union
  from reagent.publishers.union import FileSystemPublisher, ModelPublisher__Union
  from reagent.replay_memory.circular_replay_buffer import ReplayBuffer
  from reagent.replay_memory.utils import replay_buffer_to_pre_timeline_df
  from .types import TableSpec
label_desc: Use image node_id 5 for calling a global function with example usage: timeline_operator(pkl_path, input_table_spec) without return types