def test_init(self):
    operator = LocalFilesystemToWasbOperator(task_id='wasb_operator_1', dag=self.dag, **self._config)
    assert (operator.file_path == self._config['file_path'])
    assert (operator.container_name == self._config['container_name'])
    assert (operator.blob_name == self._config['blob_name'])
    assert (operator.wasb_conn_id == self._config['wasb_conn_id'])
    assert (operator.load_options == {})
    assert (operator.retries == self._config['retries'])
    operator = LocalFilesystemToWasbOperator(task_id='wasb_operator_2', dag=self.dag, load_options={'timeout': 2}, **self._config)
    assert (operator.load_options == {'timeout': 2})
def test_init(self):
    operator = LocalFilesystemToWasbOperator(task_id='wasb_operator_1', dag=self.dag, **self._config)
    assert (operator.file_path == self._config['file_path'])
    assert (operator.container_name == self._config['container_name'])
    assert (operator.blob_name == self._config['blob_name'])
    assert (operator.wasb_conn_id == self._config['wasb_conn_id'])
    assert (operator.load_options == {})
    assert (operator.retries == self._config['retries'])
    operator = LocalFilesystemToWasbOperator(task_id='wasb_operator_2', dag=self.dag, load_options={'timeout': 2}, **self._config)
    assert (operator.load_options == {'timeout': 2})