|
@@ -46,6 +46,7 @@ from desktop.auth import forms as auth_forms
|
|
|
from desktop.auth.backend import OIDCBackend
|
|
from desktop.auth.backend import OIDCBackend
|
|
|
from desktop.auth.forms import ImpersonationAuthenticationForm, OrganizationUserCreationForm, OrganizationAuthenticationForm
|
|
from desktop.auth.forms import ImpersonationAuthenticationForm, OrganizationUserCreationForm, OrganizationAuthenticationForm
|
|
|
from desktop.conf import OAUTH, ENABLE_ORGANIZATIONS
|
|
from desktop.conf import OAUTH, ENABLE_ORGANIZATIONS
|
|
|
|
|
+from desktop.lib import fsmanager
|
|
|
from desktop.lib.django_util import render, login_notrequired, JsonResponse
|
|
from desktop.lib.django_util import render, login_notrequired, JsonResponse
|
|
|
from desktop.lib.exceptions_renderable import PopupException
|
|
from desktop.lib.exceptions_renderable import PopupException
|
|
|
from desktop.log.access import access_log, access_warn, last_access_map
|
|
from desktop.log.access import access_log, access_warn, last_access_map
|
|
@@ -146,7 +147,8 @@ def dt_login(request, from_modal=False):
|
|
|
|
|
|
|
|
if request.session.test_cookie_worked():
|
|
if request.session.test_cookie_worked():
|
|
|
request.session.delete_test_cookie()
|
|
request.session.delete_test_cookie()
|
|
|
-
|
|
|
|
|
|
|
+ if request.fs is None:
|
|
|
|
|
+ request.fs = fsmanager.get_filesystem(request.fs_ref)
|
|
|
try:
|
|
try:
|
|
|
ensure_home_directory(request.fs, user)
|
|
ensure_home_directory(request.fs, user)
|
|
|
except (IOError, WebHdfsException) as e:
|
|
except (IOError, WebHdfsException) as e:
|
|
@@ -184,6 +186,8 @@ def dt_login(request, from_modal=False):
|
|
|
'KnoxSpnegoDjangoBackend' in backend_names or 'SpnegoDjangoBackend' in backend_names or 'OIDCBackend' in backend_names or
|
|
'KnoxSpnegoDjangoBackend' in backend_names or 'SpnegoDjangoBackend' in backend_names or 'OIDCBackend' in backend_names or
|
|
|
'SAML2Backend' in backend_names
|
|
'SAML2Backend' in backend_names
|
|
|
) and request.user.is_authenticated():
|
|
) and request.user.is_authenticated():
|
|
|
|
|
+ if request.fs is None:
|
|
|
|
|
+ request.fs = fsmanager.get_filesystem(request.fs_ref)
|
|
|
try:
|
|
try:
|
|
|
ensure_home_directory(request.fs, request.user)
|
|
ensure_home_directory(request.fs, request.user)
|
|
|
except (IOError, WebHdfsException) as e:
|
|
except (IOError, WebHdfsException) as e:
|