<s> """<STR_LIT>""" <EOL> from . activity import Activity <EOL> from . schedule import Schedule <EOL> from . . config import Config <EOL> from . . utils import constants as const <EOL> from . . utils . exceptions import ETLInputError <EOL> config = Config ( ) <EOL> MAX_RETRIES = config . etl . get ( '<STR_LIT>' , const . ZERO ) <EOL> RETRY_DELAY = config . etl . get ( '<STR_LIT>' , const . DEFAULT_DELAY ) <EOL> class CopyActivity ( Activity ) : <EOL> """<STR_LIT>""" <EOL> def __init__ ( self , <EOL> id , <EOL> input_node , <EOL> output_node , <EOL> schedule , <EOL> resource = None , <EOL> worker_group = None , <EOL> max_retries = None , <EOL> depends_on = None , <EOL> ** kwargs ) : <EOL> """<STR_LIT>""" <EOL> if not isinstance ( schedule , Schedule ) : <EOL> raise ETLInputError ( <EOL> '<STR_LIT>' ) <EOL> if depends_on is None : <EOL> depends_on = [ ] <EOL> if max_retries is None : <EOL> max_retries = MAX_RETRIES <EOL> super ( CopyActivity , self ) . __init__ ( <EOL> id = id , <EOL> retryDelay = RETRY_DELAY , <EOL> type = '<STR_LIT>' , <EOL> maximumRetries = max_retries , <EOL> dependsOn = depends_on , <EOL> input = input_node , <EOL> output = output_node , <EOL> runsOn = resource , <EOL> workerGroup = worker_group , <EOL> schedule = schedule , <EOL> ) </s>
