diff --git a/doc/Connecteurs-Import/Octopus/SRC_AFFECTATION_RECHERCHE.sql b/doc/Connecteurs-Import/Octopus/SRC_AFFECTATION_RECHERCHE.sql
index 0c27c0977ab9c24cab3aaa54c4c219d7adc5d570..d3ee4876946ec5d3c5a1ee165148c30710d21a47 100644
--- a/doc/Connecteurs-Import/Octopus/SRC_AFFECTATION_RECHERCHE.sql
+++ b/doc/Connecteurs-Import/Octopus/SRC_AFFECTATION_RECHERCHE.sql
@@ -4,8 +4,9 @@ WITH affectation_recherche AS (
  	SELECT
  		indaff.individu_id           z_code,
  		s.id     					 z_structure_recherche_id,
- 		indaff.id                    source_code
- 	from
+ 		indaff.id                    source_code,
+ 		s.code                       code
+ 	FROM
  		octo.individu_affectation@octoprod indaff
  	    JOIN octo.v_structure@octoprod s ON s.id = indaff.structure_id
  	WHERE
@@ -17,8 +18,11 @@ SELECT DISTINCT i.id                intervenant_id,
                 s.id                structure_id,
                 src.id              source_id,
                 i.id || '_' || s.id source_code,
-                s.libelle_court    labo_libelle
+                s.libelle_court     labo_libelle
 FROM affectation_recherche affrech
          JOIN source src ON src.code = 'Octopus'
-         JOIN intervenant i ON i.code = CAST(affrech.z_code AS varchar(255))  AND i.annee_id = unicaen_import.get_current_annee
-         JOIN octo.v_structure@octoprod s ON affrech.z_structure_recherche_id = s.id
\ No newline at end of file
+         JOIN intervenant i
+              ON i.code = CAST(affrech.z_code AS varchar(255)) AND i.annee_id = unicaen_import.get_current_annee
+         JOIN structure s ON s.code = affrech.code
+
+