|
42 | 42 | "outputs": [], |
43 | 43 | "source": [ |
44 | 44 | "def evaluate_with_gpaw(task_dict, kpts, encut):\n", |
| 45 | + " import os\n", |
| 46 | + " os.environ[\"OMP_NUM_THREADS\"] = \"1\"\n", |
| 47 | + " os.environ[\"GPAW_MPI4PY\"] = \"1\"\n", |
| 48 | + "\n", |
| 49 | + " from mpi4py import MPI\n", |
45 | 50 | " from gpaw import GPAW, PW\n", |
| 51 | + " from gpaw.mpi4pywrapper import MPI4PYWrapper\n", |
46 | 52 | "\n", |
47 | 53 | " structure = task_dict[\"calc_energy\"].copy()\n", |
48 | 54 | " structure.calc = GPAW(\n", |
49 | 55 | " xc=\"PBE\",\n", |
50 | 56 | " mode=PW(encut),\n", |
51 | 57 | " kpts=kpts,\n", |
| 58 | + " communicator=MPI4PYWrapper(MPI.COMM_WORLD),\n", |
52 | 59 | " )\n", |
53 | 60 | " return structure.get_potential_energy()" |
54 | 61 | ] |
|
67 | 74 | "outputs": [], |
68 | 75 | "source": [ |
69 | 76 | "task_dict = get_tasks_for_energy_volume_curve(\n", |
70 | | - " structure=bulk(\"Al\", a=4.05, cubic=True),\n", |
| 77 | + " structure=bulk(\"Al\", a=4.05),\n", |
71 | 78 | " num_points=7,\n", |
72 | 79 | " vol_range=0.05,\n", |
73 | 80 | " axes=(\"x\", \"y\", \"z\"),\n", |
|
219 | 226 | " task_dict=v, \n", |
220 | 227 | " kpts=(3, 3, 3), \n", |
221 | 228 | " encut=300,\n", |
222 | | - " resource_dict={\"cores\": 1},\n", |
| 229 | + " resource_dict={\"cores\": 2},\n", |
223 | 230 | " )\n", |
224 | 231 | " sleep(1)\n", |
225 | 232 | " pprint.pp(subprocess.check_output([\"flux\", \"jobs\", \"-a\"], universal_newlines=True).split(\"\\n\"))\n", |
|
416 | 423 | " task_dict=v, \n", |
417 | 424 | " kpts=(3, 3, 3), \n", |
418 | 425 | " encut=300,\n", |
419 | | - " resource_dict={\"cores\": 1},\n", |
| 426 | + " resource_dict={\"cores\": 2},\n", |
420 | 427 | " )\n", |
421 | 428 | " sleep(1)\n", |
422 | 429 | " pprint.pp(subprocess.check_output([\"flux\", \"jobs\", \"-a\"], universal_newlines=True).split(\"\\n\"))\n", |
|
0 commit comments