getindata/dbt-airflow-factory

Indicates that a set of similar lines has been detected among multiple file. This usually means that the code should be refactored to avoid this duplication. ==dbtairflowfactory.notifications.msteamswebhookhook:58 ==dbtairflowfactory.notifications.msteamswebhookoperator:65 self.message = message self.subtitle = subtitle self.buttontext = buttontext self.buttonurl = buttonurl self.themecolor = themecolor self.proxy = proxy

Indicates that a set of similar lines has been detected among multiple file. This usually means that the code should be refactored to avoid this duplication. ==dbtairflowfactory.bash.bashoperator:36 ==dbtairflowfactory.ecs.ecsoperator:25 ==dbtairflowfactory.k8s.k8soperator:44 def create( self, name: str, command: str, model: Optional[str] = None, additionaldbt_args: Optional[List[str]] = None, ) -> BaseOperator:

Indicates that a set of similar lines has been detected among multiple file. This usually means that the code should be refactored to avoid this duplication. ==dbtairflowfactory.notifications.msteamswebhookhook:43 ==dbtairflowfactory.notifications.msteamswebhookoperator:50 def init( self, httpconnid: Optional[str] = None, webhooktoken: Optional[str] = None, message: str = , subtitle: str =, buttontext: str = , button_url: str =, theme_color: str = 00FF00, proxy: Optional[str] = None,

Indicates that a set of similar lines has been detected among multiple file. This usually means that the code should be refactored to avoid this duplication. ==dbtairflowfactory.bash.bashoperator:36 ==dbtairflowfactory.k8s.k8soperator:44 def create( self, name: str, command: str, model: Optional[str] = None, additionaldbtargs: Optional[List[str]] = None, ) -> BaseOperator: return self.create(self.preparearguments(command, model, additionaldbt_args), name)

def preparearguments( self, command: str, model: Optional[str], additionaldbtargs: Optional[List[str]], ) -> List[str]: args = [

Indicates that a set of similar lines has been detected among multiple file. This usually means that the code should be refactored to avoid this duplication. ==dbtairflowfactory.bash.bashoperator:53 ==dbtairflowfactory.k8s.k8soperator:61 f{command}, f--target {self.dbt_execution_env_parameters.target}, f'--vars {self.dbt_execution_env_parameters.vars}', f--project-dir {self.dbt_execution_env_parameters.project_dir_path}, f--profiles-dir {self.dbt_execution_env_parameters.profile_dir_path}, ] if model: args += [f--select {model}] if additionaldbtargs: args += additionaldbtargs return [.join(args)]