Replace assigment with Augmented assignment (#10468)

apache · Aug 22, 2020 · 7c206a8 · 7c206a8
1 parent 44a36b9
commit 7c206a8
Show file tree

Hide file tree

Showing 12 changed files with 16 additions and 16 deletions.
diff --git a/airflow/providers/amazon/aws/hooks/datasync.py b/airflow/providers/amazon/aws/hooks/datasync.py
@@ -303,7 +303,7 @@ def wait_for_task_execution(self, task_execution_arn, max_iterations=2 * 180):
  )
  status = task_execution["Status"]
  self.log.info("status=%s", status)
- iterations = iterations - 1
+ iterations -= 1
  if status in self.TASK_EXECUTION_FAILURE_STATES:
  break
  if status in self.TASK_EXECUTION_SUCCESS_STATES:

diff --git a/airflow/providers/amazon/aws/hooks/logs.py b/airflow/providers/amazon/aws/hooks/logs.py
@@ -84,7 +84,7 @@ def get_log_events(self, log_group, log_stream_name, start_time=0, skip=0, start
  events = events[skip:]
  skip = 0
  else:
- skip = skip - event_count
+ skip -= event_count
  events = []
 
  yield from events

diff --git a/airflow/providers/amazon/aws/hooks/sagemaker.py b/airflow/providers/amazon/aws/hooks/sagemaker.py
@@ -672,7 +672,7 @@ def check_status(self, job_name, key,
 
  while running:
  time.sleep(check_interval)
- sec = sec + check_interval
+ sec += check_interval
 
  try:
  response = describe_function(job_name)
@@ -761,7 +761,7 @@ def check_training_status_with_log(self, job_name, non_terminal_states, failed_s
 
  while True:
  time.sleep(check_interval)
- sec = sec + check_interval
+ sec += check_interval
 
  state, last_description, last_describe_job_call = \
  self.describe_training_job_with_log(job_name, positions, stream_names,

diff --git a/airflow/providers/apache/druid/hooks/druid.py b/airflow/providers/apache/druid/hooks/druid.py
@@ -120,7 +120,7 @@ def submit_indexing_job(self, json_index_spec: Dict[str, Any]) -> None:
 
  time.sleep(self.timeout)
 
- sec = sec + self.timeout
+ sec += self.timeout
 
  status = req_status.json()['status']['status']
  if status == 'RUNNING':

diff --git a/airflow/providers/apache/hive/hooks/hive.py b/airflow/providers/apache/hive/hooks/hive.py
@@ -211,7 +211,7 @@ def run_cli(self,
 
  with TemporaryDirectory(prefix='airflow_hiveop_') as tmp_dir:
  with NamedTemporaryFile(dir=tmp_dir) as f:
- hql = hql + '\n'
+ hql += '\n'
  f.write(hql.encode('UTF-8'))
  f.flush()
  hive_cmd = self._prepare_cli_cmd()

diff --git a/airflow/providers/apache/spark/hooks/spark_submit.py b/airflow/providers/apache/spark/hooks/spark_submit.py
@@ -587,7 +587,7 @@ def _start_driver_status_tracking(self) -> None:
 
  if returncode:
  if missed_job_status_reports < max_missed_job_status_reports:
- missed_job_status_reports = missed_job_status_reports + 1
+ missed_job_status_reports += 1
  else:
  raise AirflowException(
  "Failed to poll for the driver status {} times: returncode = {}"

diff --git a/airflow/providers/cncf/kubernetes/operators/kubernetes_pod.py b/airflow/providers/cncf/kubernetes/operators/kubernetes_pod.py
@@ -317,11 +317,11 @@ def handle_pod_overlap(self, labels, try_numbers_match, launcher, pod_list):
  log_line = "found a running pod with labels {} but a different try_number.".format(labels)
 
  if self.reattach_on_restart:
- log_line = log_line + " Will attach to this pod and monitor instead of starting new one"
+ log_line += " Will attach to this pod and monitor instead of starting new one"
  self.log.info(log_line)
  final_state, result = self.monitor_launched_pod(launcher, pod_list.items[0])
  else:
- log_line = log_line + "creating pod with labels {} and launcher {}".format(labels, launcher)
+ log_line += "creating pod with labels {} and launcher {}".format(labels, launcher)
  self.log.info(log_line)
  final_state, _, result = self.create_new_pod_for_operator(labels, launcher)
  return final_state, result

diff --git a/airflow/providers/google/cloud/hooks/bigquery.py b/airflow/providers/google/cloud/hooks/bigquery.py
@@ -1165,7 +1165,7 @@ def run_grant_dataset_view_access(
  'Granting table %s:%s.%s authorized view access to %s:%s dataset.',
  view_project, view_dataset, view_table, project_id, source_dataset
  )
- dataset.access_entries = dataset.access_entries + [view_access]
+ dataset.access_entries += [view_access]
  dataset = self.update_dataset(
  fields=["access"],
  dataset_resource=dataset.to_api_repr(),
@@ -1423,7 +1423,7 @@ def cancel_job(
 
  job_complete = False
  while polling_attempts < max_polling_attempts and not job_complete:
- polling_attempts = polling_attempts + 1
+ polling_attempts += 1
  job_complete = self.poll_job_complete(job_id)
  if job_complete:
  self.log.info('Job successfully canceled: %s, %s', project_id, job_id)

diff --git a/airflow/providers/jenkins/example_dags/example_jenkins_job_trigger.py b/airflow/providers/jenkins/example_dags/example_jenkins_job_trigger.py
@@ -61,7 +61,7 @@ def grab_artifact_from_jenkins(**context):
  # The JenkinsJobTriggerOperator store the job url in the xcom variable corresponding to the task
  # You can then use it to access things or to get the job number
  # This url looks like : http://jenkins_url/job/job_name/job_number/
- url = url + "artifact/myartifact.xml" # Or any other artifact name
+ url += "artifact/myartifact.xml" # Or any other artifact name
  request = Request(url)
  response = jenkins_server.jenkins_open(request)
  return response # We store the artifact content in a xcom variable for later use

diff --git a/airflow/providers/jenkins/operators/jenkins_job_trigger.py b/airflow/providers/jenkins/operators/jenkins_job_trigger.py
@@ -160,7 +160,7 @@ def poll_job_in_queue(self, location: str, jenkins_server: Jenkins) -> int:
  :return: The build_number corresponding to the triggered job
  """
  try_count = 0
- location = location + '/api/json'
+ location += '/api/json'
  # TODO Use get_queue_info instead
  # once it will be available in python-jenkins (v > 0.4.15)
  self.log.info('Polling jenkins queue at the url %s', location)

diff --git a/airflow/providers/oracle/transfers/oracle_to_oracle.py b/airflow/providers/oracle/transfers/oracle_to_oracle.py
@@ -75,7 +75,7 @@ def _execute(self, src_hook, dest_hook, context):
  rows_total = 0
  rows = cursor.fetchmany(self.rows_chunk)
  while len(rows) > 0:
- rows_total = rows_total + len(rows)
+ rows_total += len(rows)
  dest_hook.bulk_insert_rows(self.destination_table, rows,
  target_fields=target_fields,
  commit_every=self.rows_chunk)

diff --git a/airflow/providers/singularity/operators/singularity.py b/airflow/providers/singularity/operators/singularity.py
@@ -118,11 +118,11 @@ def execute(self, context):
 
  # Prepare list of binds
  for bind in self.volumes:
- self.options = self.options + ['--bind', bind]
+ self.options += ['--bind', bind]
 
  # Does the user want a custom working directory?
  if self.working_dir is not None:
- self.options = self.options + ['--workdir', self.working_dir]
+ self.options += ['--workdir', self.working_dir]
 
  # Export environment before instance is run
  for enkey, envar in self.environment.items():