@mock.patch('airflow.providers.microsoft.azure.transfers.local_to_wasb.WasbHook', autospec=True)
def test_execute(self, mock_hook):
    mock_instance = mock_hook.return_value
    operator = LocalFilesystemToWasbOperator(task_id='wasb_sensor', dag=self.dag, load_options={'timeout': 2}, **self._config)
    operator.execute(None)
    mock_instance.load_file.assert_called_once_with('file', 'container', 'blob', timeout=2)
@mock.patch('airflow.providers.microsoft.azure.transfers.local_to_wasb.WasbHook', autospec=True)
def test_execute(self, mock_hook):
    mock_instance = mock_hook.return_value
    operator = LocalFilesystemToWasbOperator(task_id='wasb_sensor', dag=self.dag, load_options={'timeout': 2}, **self._config)
    operator.execute(None)
    mock_instance.load_file.assert_called_once_with('file', 'container', 'blob', timeout=2)