Module Expr Str ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias identifier ImportFrom alias Assign NameStore Call NameLoad Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Str AttributeLoad NameLoad attr ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad NameLoad kwarg body Expr Str If UnaryOpNot Call NameLoad NameLoad NameLoad body Raise Call NameLoad Str If CompareIs NameLoad NameLoad body Assign NameStore ListLoad If CompareIs NameLoad NameLoad body Assign NameStore NameLoad Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr keyword NameLoad keyword NameLoad keyword Str keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad decorator_list decorator_list
N/A N/A 
Pipeline object class for CopyActivity
 activity Activity schedule Schedule config Config utils constants const utils.exceptions ETLInputError N/A config N/A Config N/A MAX_RETRIES N/A N/A N/A config etl get MAX_RETRIES N/A const ZERO N/A RETRY_DELAY N/A N/A N/A config etl get RETRY_DELAY N/A const DEFAULT_DELAY CopyActivity N/A Activity N/A N/A EC2 Resource class
     __init__ N/A N/A self id input_node output_node schedule resource worker_group max_retries depends_on N/A None None None None kwargs N/A N/A Constructor for the CopyActivity class

        Args:
            id(str): id of the object
            input_node(S3Node / list of S3Nodes): input nodes for the activity
            output_node(S3Node / list of S3Nodes): output nodes for activity
            schedule(Schedule): schedule of the pipeline
            resource(Ec2Resource / EmrResource): resource to run the activity on
            worker_group(str): the worker group to run the activity on
            max_retries(int): number of retries for the activity
            depends_on(list of activities): dependendent pipelines steps
            **kwargs(optional): Keyword arguments directly passed to base class
         N/A N/A N/A isinstance schedule Schedule N/A N/A N/A ETLInputError Input schedule must be of the type Schedule N/A N/A depends_on None N/A N/A depends_on N/A N/A N/A max_retries None N/A N/A max_retries MAX_RETRIES N/A N/A N/A N/A super CopyActivity self __init__ id id retryDelay RETRY_DELAY type CopyActivity maximumRetries max_retries dependsOn depends_on input input_node output output_node runsOn resource workerGroup worker_group schedule schedule N/A N/A